Uses of Class
org.apache.flink.table.catalog.IntervalFreshness

Packages that use IntervalFreshness

Package	Description
org.apache.flink.table.catalog

Uses of IntervalFreshness in org.apache.flink.table.catalog

Methods in org.apache.flink.table.catalog that return IntervalFreshness

Modifier and Type	Method	Description
static IntervalFreshness	IntervalFreshness.fromDuration(Duration duration)	Creates an IntervalFreshness from a Duration, choosing the most appropriate time unit.
IntervalFreshness	CatalogMaterializedTable.getDefinitionFreshness()	Get the definition freshness of materialized table which is used to determine the physical refresh mode.
IntervalFreshness	DefaultCatalogMaterializedTable.getDefinitionFreshness()
IntervalFreshness	ResolvedCatalogMaterializedTable.getDefinitionFreshness()
IntervalFreshness	MaterializedTableEnrichmentResult.getFreshness()
static IntervalFreshness	IntervalFreshness.of(String interval, IntervalFreshness.TimeUnit timeUnit)
static IntervalFreshness	IntervalFreshness.ofDay(String interval)
static IntervalFreshness	IntervalFreshness.ofHour(String interval)
static IntervalFreshness	IntervalFreshness.ofMinute(String interval)
static IntervalFreshness	IntervalFreshness.ofSecond(String interval)

Methods in org.apache.flink.table.catalog with parameters of type IntervalFreshness

Modifier and Type	Method	Description
static String	IntervalFreshness.convertFreshnessToCron(IntervalFreshness intervalFreshness)	Converts the freshness of materialized table to cron expression in full refresh mode.
CatalogMaterializedTable.RefreshMode	DefaultMaterializedTableEnricher.deriveRefreshMode(CatalogMaterializedTable.LogicalRefreshMode logicalRefreshMode, IntervalFreshness freshness, Duration threshold)	Determines physical refresh mode: CONTINUOUS if freshness is below threshold or explicitly requested, otherwise FULL (validated for cron conversion).
CatalogMaterializedTable.Builder	CatalogMaterializedTable.Builder.freshness(IntervalFreshness freshness)
static void	IntervalFreshness.validateFreshnessForCron(IntervalFreshness intervalFreshness)	Validates that the given freshness can be converted to a cron expression in full refresh mode.

Constructors in org.apache.flink.table.catalog with parameters of type IntervalFreshness

Constructor	Description
DefaultCatalogMaterializedTable(Schema schema, String comment, TableDistribution distribution, List<String> partitionKeys, Map<String,String> options, Long snapshot, String definitionQuery, IntervalFreshness freshness, CatalogMaterializedTable.LogicalRefreshMode logicalRefreshMode, CatalogMaterializedTable.RefreshMode refreshMode, CatalogMaterializedTable.RefreshStatus refreshStatus, String refreshHandlerDescription, byte[] serializedRefreshHandler)
MaterializedTableEnrichmentResult(IntervalFreshness freshness, CatalogMaterializedTable.RefreshMode refreshMode)
ResolvedCatalogMaterializedTable(CatalogMaterializedTable origin, ResolvedSchema resolvedSchema, CatalogMaterializedTable.RefreshMode refreshMode, IntervalFreshness freshness)