@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.
DynamicTableSourceFactory for constructing a
DynamicTableSinkFactory for constructing a
implicitly added and must not be declared.
|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
factoryIdentifier, optionalOptions, requiredOptions
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–2023 The Apache Software Foundation. All rights reserved.