Package org.apache.flink.table.catalog
Interface MaterializedTableEnricher
-
- All Known Implementing Classes:
DefaultMaterializedTableEnricher
@Experimental public interface MaterializedTableEnricherEnricher interface for determining materialized table properties during catalog resolution.This enricher resolves:
- Freshness intervals when not explicitly specified by the user
- Physical refresh modes (CONTINUOUS or FULL) based on logical preferences and configuration
Implementations can provide custom strategies tailored to different deployment environments or operational requirements.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description MaterializedTableEnrichmentResultenrich(CatalogMaterializedTable catalogMaterializedTable)Enriches a materialized table by determining its final freshness interval and refresh mode.
-
-
-
Method Detail
-
enrich
MaterializedTableEnrichmentResult enrich(CatalogMaterializedTable catalogMaterializedTable)
Enriches a materialized table by determining its final freshness interval and refresh mode.- Parameters:
catalogMaterializedTable- the materialized table to enrich, which may have null freshness- Returns:
- the enrichment result with resolved, non-null freshness and refresh mode
-
-