public class HiveDynamicTableFactory extends Object implements DynamicTableSourceFactory, DynamicTableSinkFactory
HiveTableFactory
.DynamicTableFactory.Context
Constructor and Description |
---|
HiveDynamicTableFactory() |
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<?>> |
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 String factoryIdentifier()
Factory
For 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. kafka-0.10
).
factoryIdentifier
in interface Factory
public Set<ConfigOption<?>> requiredOptions()
Factory
ConfigOption
that an implementation of this factory requires in
addition to Factory.optionalOptions()
.
See the documentation of Factory
for more information.
requiredOptions
in interface Factory
public Set<ConfigOption<?>> optionalOptions()
Factory
ConfigOption
that an implementation of this factory consumes in
addition to Factory.requiredOptions()
.
See the documentation of Factory
for more information.
optionalOptions
in interface Factory
public DynamicTableSink createDynamicTableSink(DynamicTableFactory.Context context)
DynamicTableSinkFactory
DynamicTableSink
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 DynamicTableSinkFactory
public DynamicTableSource createDynamicTableSource(DynamicTableFactory.Context context)
DynamicTableSourceFactory
DynamicTableSource
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 DynamicTableSourceFactory
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.