Modifier and Type | Class and Description |
---|---|
class |
HBaseDynamicTableFactory
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 |
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 |
Kafka010DynamicTableFactory
Factory for creating configured instances of
Kafka010DynamicSource . |
class |
Kafka011DynamicTableFactory
Factory for creating configured instances of
Kafka011DynamicSource . |
class |
KafkaDynamicTableFactory
Factory for creating configured instances of
KafkaDynamicSource . |
class |
KafkaDynamicTableFactoryBase
Factory for creating configured instances of
KafkaDynamicSourceBase and KafkaDynamicSinkBase . |
Modifier and Type | Class and Description |
---|---|
class |
BlackHoleTableSinkFactory
Black hole table sink factory swallowing all input records.
|
class |
PrintTableSinkFactory
Print table sink factory writing every row to the standard output or standard error stream.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.