Modifier and Type | Class and Description |
---|---|
class |
AsyncDynamicTableSinkFactory
Abstract Implementation of
DynamicTableSinkFactory having AsyncSinkBase fields as
optional table options defined in AsyncSinkConnectorOptions . |
Modifier and Type | Class and Description |
---|---|
class |
BlackHoleTableSinkFactory
Black hole table sink factory swallowing all input records.
|
Modifier and Type | Class and Description |
---|---|
class |
DataGenTableSourceFactory
Factory for creating configured instances of
DataGenTableSource in a stream environment. |
Modifier and Type | Class and Description |
---|---|
class |
FileSystemTableFactory
File system
TableFactory . |
Modifier and Type | Class and Description |
---|---|
class |
KinesisFirehoseDynamicTableFactory
Factory for creating
KinesisFirehoseDynamicSink . |
Modifier and Type | Class and Description |
---|---|
class |
HBase1DynamicTableFactory
HBase connector factory.
|
Modifier and Type | Class and Description |
---|---|
class |
HBase2DynamicTableFactory
HBase connector factory.
|
Modifier and Type | Class and Description |
---|---|
class |
JdbcDynamicTableFactory
Factory for creating configured instances of
JdbcDynamicTableSource and JdbcDynamicTableSink . |
Modifier and Type | Class and Description |
---|---|
class |
KinesisDynamicTableSinkFactory
Factory for creating
KinesisDynamicSink . |
Modifier and Type | Class and Description |
---|---|
class |
PrintTableSinkFactory
Print table sink factory writing every row to the standard output or standard error stream.
|
Modifier and Type | Class and Description |
---|---|
class |
UpsertTestDynamicTableSinkFactory
A
DynamicTableSinkFactory for discovering UpsertTestDynamicTableSink . |
Modifier and Type | Class and Description |
---|---|
class |
HiveDynamicTableFactory
A dynamic table factory implementation for Hive catalog.
|
Modifier and Type | Class and Description |
---|---|
class |
KafkaDynamicTableFactory
Factory for creating configured instances of
KafkaDynamicSource and KafkaDynamicSink . |
class |
UpsertKafkaDynamicTableFactory
Upsert-Kafka factory.
|
Modifier and Type | Class and Description |
---|---|
class |
KinesisDynamicTableFactory
Factory for creating
KinesisDynamicSource . |
Modifier and Type | Class and Description |
---|---|
class |
SocketDynamicTableFactory
The
SocketDynamicTableFactory translates the catalog table to a table source. |
Modifier and Type | Interface and Description |
---|---|
interface |
DynamicTableSinkFactory
Creates a
DynamicTableSink instance from a CatalogTable and additional context
information. |
interface |
DynamicTableSourceFactory
Creates a
DynamicTableSource instance from a CatalogTable and additional context
information. |
interface |
ManagedTableFactory
Base interface for configuring a managed dynamic table connector.
|
Modifier and Type | Method and Description |
---|---|
static FactoryUtil.TableFactoryHelper |
FactoryUtil.createTableFactoryHelper(DynamicTableFactory factory,
DynamicTableFactory.Context context)
Creates a utility that helps in discovering formats, merging options with
DynamicTableFactory.Context.getEnrichmentOptions() and validating them all for a DynamicTableFactory . |
Modifier and Type | Class and Description |
---|---|
class |
PythonDynamicTableFactory
Table source factory for PythonDynamicTableSource.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.