Package org.apache.flink.table.catalog

Class DefaultMaterializedTableEnricher

java.lang.Object

org.apache.flink.table.catalog.DefaultMaterializedTableEnricher

All Implemented Interfaces:

MaterializedTableEnricher

@Internal
public class DefaultMaterializedTableEnricher
extends Object
implements MaterializedTableEnricher

Default implementation of MaterializedTableEnricher.

Applies default freshness values based on refresh mode and determines the physical refresh mode using freshness threshold comparison.

Method Summary

Modifier and Type	Method	Description
static DefaultMaterializedTableEnricher	create(Duration defaultContinuousFreshness, Duration defaultFullFreshness, Duration freshnessThreshold)
CatalogMaterializedTable.RefreshMode	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).
MaterializedTableEnrichmentResult	enrich(CatalogMaterializedTable table)	Enriches a materialized table by determining its final freshness interval and refresh mode.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

create

public static DefaultMaterializedTableEnricher create(Duration defaultContinuousFreshness,
                                                      Duration defaultFullFreshness,
                                                      Duration freshnessThreshold)

enrich

public MaterializedTableEnrichmentResult enrich(CatalogMaterializedTable table)

Description copied from interface: MaterializedTableEnricher

Enriches a materialized table by determining its final freshness interval and refresh mode.

Specified by:

enrich in interface MaterializedTableEnricher

Parameters:

table - the materialized table to enrich, which may have null freshness

Returns:

the enrichment result with resolved, non-null freshness and refresh mode

deriveRefreshMode

public CatalogMaterializedTable.RefreshMode 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).