org.apache.flink.table.planner.utils

Class MaterializedTableUtils

java.lang.Object

org.apache.flink.table.planner.utils.MaterializedTableUtils

@Internal
public class MaterializedTableUtils
extends Object

The utils for materialized table.

Constructor Summary

Constructors

Constructor and Description
MaterializedTableUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.table.catalog.CatalogMaterializedTable.LogicalRefreshMode	deriveLogicalRefreshMode(org.apache.flink.sql.parser.ddl.SqlRefreshMode sqlRefreshMode)
static org.apache.flink.table.catalog.CatalogMaterializedTable.RefreshMode	deriveRefreshMode(Duration threshold, Duration definedFreshness, org.apache.flink.table.catalog.CatalogMaterializedTable.LogicalRefreshMode definedRefreshMode)
static org.apache.flink.table.catalog.IntervalFreshness	getMaterializedTableFreshness(org.apache.calcite.sql.SqlIntervalLiteral sqlIntervalLiteral)

Methods inherited from class java.lang.Object

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

Constructor Detail

MaterializedTableUtils

public MaterializedTableUtils()

Method Detail

getMaterializedTableFreshness

public static org.apache.flink.table.catalog.IntervalFreshness getMaterializedTableFreshness(org.apache.calcite.sql.SqlIntervalLiteral sqlIntervalLiteral)

deriveLogicalRefreshMode

public static org.apache.flink.table.catalog.CatalogMaterializedTable.LogicalRefreshMode deriveLogicalRefreshMode(org.apache.flink.sql.parser.ddl.SqlRefreshMode sqlRefreshMode)

deriveRefreshMode

public static org.apache.flink.table.catalog.CatalogMaterializedTable.RefreshMode deriveRefreshMode(Duration threshold,
                                                                                                    Duration definedFreshness,
                                                                                                    org.apache.flink.table.catalog.CatalogMaterializedTable.LogicalRefreshMode definedRefreshMode)