Modifier and Type | Method and Description |
---|---|
StreamTableSink<Tuple2<Boolean,Row>> |
HBase1TableFactory.createStreamTableSink(Map<String,String> properties) |
Modifier and Type | Class and Description |
---|---|
class |
HBaseUpsertTableSink
An upsert
UpsertStreamTableSink for HBase. |
Modifier and Type | Method and Description |
---|---|
StreamTableSink<Tuple2<Boolean,Row>> |
HBase2TableFactory.createStreamTableSink(Map<String,String> properties) |
Modifier and Type | Class and Description |
---|---|
class |
JdbcUpsertTableSink
An upsert
UpsertStreamTableSink for JDBC. |
Modifier and Type | Method and Description |
---|---|
StreamTableSink<Tuple2<Boolean,Row>> |
JdbcTableSourceSinkFactory.createStreamTableSink(Map<String,String> properties) |
Modifier and Type | Class and Description |
---|---|
class |
CassandraAppendTableSink
An
AppendStreamTableSink to write an append stream Table to a Cassandra table. |
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchUpsertTableSinkBase
A version-agnostic Elasticsearch
UpsertStreamTableSink . |
Modifier and Type | Method and Description |
---|---|
StreamTableSink<Tuple2<Boolean,Row>> |
ElasticsearchUpsertTableSinkFactoryBase.createStreamTableSink(Map<String,String> properties) |
Modifier and Type | Class and Description |
---|---|
class |
Elasticsearch6UpsertTableSink
Version-specific upsert table sink for Elasticsearch 6.
|
Modifier and Type | Class and Description |
---|---|
class |
Elasticsearch7UpsertTableSink
Version-specific upsert table sink for Elasticsearch 7.
|
Modifier and Type | Class and Description |
---|---|
class |
KafkaTableSink
Deprecated.
Use
KafkaDynamicSink via KafkaDynamicTableFactory . |
class |
KafkaTableSinkBase
Deprecated.
Use
KafkaDynamicSink via KafkaDynamicTableFactory . |
Modifier and Type | Method and Description |
---|---|
StreamTableSink<Row> |
KafkaTableSourceSinkFactoryBase.createStreamTableSink(Map<String,String> properties)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectBatchTableSink
Table sink for collecting the results locally all at once using accumulators.
|
class |
CollectStreamTableSink
Table sink for collecting the results locally using sockets.
|
Modifier and Type | Method and Description |
---|---|
default StreamTableSink<T> |
StreamTableSinkFactory.createStreamTableSink(Map<String,String> properties)
Deprecated.
Context contains more information, and already contains table schema too.
Please use TableSinkFactory.createTableSink(Context) instead. |
Modifier and Type | Class and Description |
---|---|
class |
BatchSelectTableSink
A
StreamTableSink for batch select job to collect the result to local. |
class |
SelectTableSinkBase<T>
Basic implementation of
StreamTableSink for select job to collect the result to local. |
Modifier and Type | Interface and Description |
---|---|
interface |
AppendStreamTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures and only works with the Blink planner. See FLIP-95 for more
information. |
interface |
RetractStreamTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures and only works with the Blink planner. See FLIP-95 for more
information. |
interface |
UpsertStreamTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures and only works with the Blink planner. See FLIP-95 for more
information. |
Modifier and Type | Class and Description |
---|---|
class |
CsvTableSink
A simple
TableSink to emit data as CSV files. |
class |
OutputFormatTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures and only works with the Blink planner. See FLIP-95 for more
information. |
class |
StreamSelectTableSink
A
RetractStreamTableSink for streaming select job to collect the result to local. |
Modifier and Type | Method and Description |
---|---|
StreamTableSink<Row> |
CsvAppendTableSinkFactory.createStreamTableSink(Map<String,String> properties) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.