@PublicEvolving public interface DynamicTableFactory extends Factory
Dynamic tables are the core concept of Flink's Table & SQL API for processing both bounded and unbounded data in a unified fashion.
|Modifier and Type||Interface and Description|
Provides catalog and session information describing the dynamic table to be accessed.
|Modifier and Type||Method and Description|
Returns a set of
default Set<ConfigOption<?>> forwardOptions()
ConfigOptionthat are directly forwarded to the runtime implementation but don't affect the final execution topology.
Options declared here can override options of the persisted plan during an enrichment
phase. Since a restored topology is static, an implementer has to ensure that the declared
options don't affect fundamental abilities such as
For example, given a database connector, if an option defines the connection timeout,
changing this value does not affect the pipeline topology and can be allowed. However, an
option that defines whether the connector supports
SupportsReadingMetadata or not is
not allowed. The planner might not react to changed abilities anymore.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.