Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
HBase1DynamicTableFactory.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 | Method and Description |
---|---|
DynamicTableSink |
HBase2DynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
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 | Class and Description |
---|---|
class |
HiveTableSink
Table sink to write to Hive tables.
|
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
HiveTableSink.copy() |
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 |
KafkaDynamicSink
A version-agnostic Kafka
DynamicTableSink . |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
KafkaDynamicSink.copy() |
DynamicTableSink |
UpsertKafkaDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSink |
KafkaDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
KinesisDynamicSink
Kinesis-backed
DynamicTableSink . |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
KinesisDynamicSink.copy() |
DynamicTableSink |
KinesisDynamicTableFactory.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,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
Modifier and Type | Class and Description |
---|---|
class |
FileSystemTableSink
File system
DynamicTableSink . |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
FileSystemTableSink.copy() |
DynamicTableSink |
FileSystemTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.toRel(org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
CatalogSinkModifyOperation sinkOperation,
DynamicTableSink sink,
CatalogTable table)
Similar to
CatalogSourceTable.toRel(RelOptTable.ToRelContext) , converts a given
DynamicTableSink to a RelNode . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.