Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
HBaseDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseDynamicTableSink
HBase table sink implementation.
|
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
HBaseDynamicTableSink.copy() |
Modifier and Type | Class and Description |
---|---|
class |
JdbcDynamicTableSink
A
DynamicTableSink for JDBC. |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
JdbcDynamicTableSink.copy() |
DynamicTableSink |
JdbcDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
HiveDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
Elasticsearch7DynamicSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSink |
Elasticsearch6DynamicSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
Kafka010DynamicSink
Kafka 0.10 table sink for writing data into Kafka.
|
class |
Kafka011DynamicSink
Kafka 0.11 table sink for writing data into Kafka.
|
class |
KafkaDynamicSink
Kafka table sink for writing data into Kafka.
|
class |
KafkaDynamicSinkBase
A version-agnostic Kafka
DynamicTableSink . |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
KafkaDynamicSink.copy() |
DynamicTableSink |
Kafka011DynamicSink.copy() |
DynamicTableSink |
Kafka010DynamicSink.copy() |
DynamicTableSink |
KafkaDynamicTableFactoryBase.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
DynamicTableSink.copy()
Creates a copy of this instance during planning.
|
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
PrintTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSink |
BlackHoleTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSink |
DynamicTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)
Creates a
DynamicTableSink instance from a CatalogTable and additional
context information. |
static DynamicTableSink |
FactoryUtil.createTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader)
Creates a
DynamicTableSink from a CatalogTable . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.