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 |
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 |
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 | Method and Description |
---|---|
static DynamicTableSink |
FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory preferredFactory,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
Map<String,String> enrichmentOptions,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
static DynamicTableSink |
FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory preferredFactory,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
|
Modifier and Type | Method and Description |
---|---|
default Optional<DynamicTableSinkFactory> |
Module.getTableSinkFactory()
Returns a
DynamicTableSinkFactory for creating sink tables. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.