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 |
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 |
PrintTableSinkFactory
Print table sink factory writing every row to the standard output or standard error stream.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveDynamicTableFactory
A dynamic table factory implementation for Hive catalog.
|
Modifier and Type | Class and Description |
---|---|
class |
Elasticsearch6DynamicSinkFactory
A
DynamicTableSinkFactory for discovering Elasticsearch6DynamicSink . |
class |
Elasticsearch7DynamicSinkFactory
A
DynamicTableSinkFactory for discovering Elasticsearch7DynamicSink . |
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 and KinesisDynamicSink instances. |
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. |
Modifier and Type | Method and Description |
---|---|
static FactoryUtil.TableFactoryHelper |
FactoryUtil.createTableFactoryHelper(DynamicTableFactory factory,
DynamicTableFactory.Context context)
Creates a utility that helps in discovering formats and validating all options for a
DynamicTableFactory . |
Modifier and Type | Class and Description |
---|---|
class |
FileSystemTableFactory
File system
TableFactory . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.