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 |
KafkaDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSink |
UpsertKafkaDynamicTableFactory.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,
ResolvedCatalogTable 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.convertSinkToRel(org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
CatalogSinkModifyOperation sinkModifyOperation,
DynamicTableSink sink,
ResolvedCatalogTable table)
Converts a given
DynamicTableSink to a RelNode . |
Modifier and Type | Method and Description |
---|---|
void |
OverwriteSpec.apply(DynamicTableSink tableSink) |
void |
PartitioningSpec.apply(DynamicTableSink tableSink) |
void |
WritingMetadataSpec.apply(DynamicTableSink tableSink) |
void |
SinkAbilitySpec.apply(DynamicTableSink tableSink)
Apply the ability to the given
DynamicTableSink . |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
DynamicTableSinkSpec.getTableSink() |
Modifier and Type | Method and Description |
---|---|
void |
DynamicTableSinkSpec.setTableSink(DynamicTableSink tableSink) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.