@Internal public class HBase2DynamicTableFactory extends Object implements DynamicTableSourceFactory, DynamicTableSinkFactory
DynamicTableFactory.Context| Constructor and Description |
|---|
HBase2DynamicTableFactory() |
| Modifier and Type | Method and Description |
|---|---|
DynamicTableSink |
createDynamicTableSink(DynamicTableFactory.Context context)
Creates a
DynamicTableSink instance from a CatalogTable and additional
context information. |
DynamicTableSource |
createDynamicTableSource(DynamicTableFactory.Context context)
Creates a
DynamicTableSource instance from a CatalogTable and additional
context information. |
String |
factoryIdentifier()
Returns a unique identifier among same factory interfaces.
|
Set<ConfigOption<?>> |
forwardOptions()
Returns a set of
ConfigOption that are directly forwarded to the runtime
implementation but don't affect the final execution topology. |
Set<ConfigOption<?>> |
optionalOptions()
Returns a set of
ConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions(). |
Set<ConfigOption<?>> |
requiredOptions()
Returns a set of
ConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions(). |
public DynamicTableSource createDynamicTableSource(DynamicTableFactory.Context context)
DynamicTableSourceFactoryDynamicTableSource instance from a CatalogTable and additional
context information.
An implementation should perform validation and the discovery of further (nested) factories in this method.
createDynamicTableSource in interface DynamicTableSourceFactorypublic DynamicTableSink createDynamicTableSink(DynamicTableFactory.Context context)
DynamicTableSinkFactoryDynamicTableSink instance from a CatalogTable and additional
context information.
An implementation should perform validation and the discovery of further (nested) factories in this method.
createDynamicTableSink in interface DynamicTableSinkFactorypublic String factoryIdentifier()
FactoryFor consistency, an identifier should be declared as one lower case word (e.g. kafka). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. elasticsearch-7).
factoryIdentifier in interface Factorypublic Set<ConfigOption<?>> requiredOptions()
FactoryConfigOption that an implementation of this factory requires in
addition to Factory.optionalOptions().
See the documentation of Factory for more information.
requiredOptions in interface Factorypublic Set<ConfigOption<?>> optionalOptions()
FactoryConfigOption that an implementation of this factory consumes in
addition to Factory.requiredOptions().
See the documentation of Factory for more information.
optionalOptions in interface Factorypublic Set<ConfigOption<?>> forwardOptions()
DynamicTableFactoryConfigOption that 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 SupportsProjectionPushDown or
SupportsFilterPushDown.
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.
forwardOptions in interface DynamicTableFactoryDynamicTableFactory.Context.getEnrichmentOptions(),
FactoryUtil.TableFactoryHelper.getOptions(),
FormatFactory.forwardOptions()Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.