Uses of Interface
org.apache.flink.table.sinks.StreamTableSink

Packages that use StreamTableSink

Package	Description
org.apache.flink.addons.hbase
org.apache.flink.api.java.io.jdbc
org.apache.flink.connectors.hive
org.apache.flink.streaming.connectors.cassandra
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.elasticsearch6
org.apache.flink.streaming.connectors.kafka
org.apache.flink.table.client.gateway.local
org.apache.flink.table.factories
org.apache.flink.table.sinks

Uses of StreamTableSink in org.apache.flink.addons.hbase

Classes in org.apache.flink.addons.hbase that implement StreamTableSink

Modifier and Type	Class and Description
class	HBaseUpsertTableSink An upsert UpsertStreamTableSink for HBase.

Methods in org.apache.flink.addons.hbase that return StreamTableSink

Modifier and Type	Method and Description
StreamTableSink<Tuple2<Boolean,Row>>	HBaseTableFactory.createStreamTableSink(Map<String,String> properties)

Uses of StreamTableSink in org.apache.flink.api.java.io.jdbc

Classes in org.apache.flink.api.java.io.jdbc that implement StreamTableSink

Modifier and Type	Class and Description
class	JDBCAppendTableSink An at-least-once Table sink for JDBC.
class	JDBCUpsertTableSink An upsert UpsertStreamTableSink for JDBC.

Methods in org.apache.flink.api.java.io.jdbc that return StreamTableSink

Modifier and Type	Method and Description
StreamTableSink<Tuple2<Boolean,Row>>	JDBCTableSourceSinkFactory.createStreamTableSink(Map<String,String> properties)

Uses of StreamTableSink in org.apache.flink.connectors.hive

Classes in org.apache.flink.connectors.hive that implement StreamTableSink

Modifier and Type	Class and Description
class	HiveTableSink Table sink to write to Hive tables.

Uses of StreamTableSink in org.apache.flink.streaming.connectors.cassandra

Classes in org.apache.flink.streaming.connectors.cassandra that implement StreamTableSink

Modifier and Type	Class and Description
class	CassandraAppendTableSink An AppendStreamTableSink to write an append stream Table to a Cassandra table.

Uses of StreamTableSink in org.apache.flink.streaming.connectors.elasticsearch

Classes in org.apache.flink.streaming.connectors.elasticsearch that implement StreamTableSink

Modifier and Type	Class and Description
class	ElasticsearchUpsertTableSinkBase A version-agnostic Elasticsearch UpsertStreamTableSink.

Methods in org.apache.flink.streaming.connectors.elasticsearch that return StreamTableSink

Modifier and Type	Method and Description
StreamTableSink<Tuple2<Boolean,Row>>	ElasticsearchUpsertTableSinkFactoryBase.createStreamTableSink(Map<String,String> properties)

Uses of StreamTableSink in org.apache.flink.streaming.connectors.elasticsearch6

Classes in org.apache.flink.streaming.connectors.elasticsearch6 that implement StreamTableSink

Modifier and Type	Class and Description
class	Elasticsearch6UpsertTableSink Version-specific upsert table sink for Elasticsearch 6.

Uses of StreamTableSink in org.apache.flink.streaming.connectors.kafka

Classes in org.apache.flink.streaming.connectors.kafka that implement StreamTableSink

Modifier and Type	Class and Description
class	Kafka010TableSink Kafka 0.10 table sink for writing data into Kafka.
class	Kafka011TableSink Kafka 0.11 table sink for writing data into Kafka.
class	Kafka08TableSink Kafka 0.8 table sink for writing data into Kafka.
class	Kafka09TableSink Kafka 0.9 table sink for writing data into Kafka.
class	KafkaTableSink Kafka table sink for writing data into Kafka.
class	KafkaTableSinkBase A version-agnostic Kafka AppendStreamTableSink.

Methods in org.apache.flink.streaming.connectors.kafka that return StreamTableSink

Modifier and Type	Method and Description
StreamTableSink<Row>	KafkaTableSourceSinkFactoryBase.createStreamTableSink(Map<String,String> properties)

Uses of StreamTableSink in org.apache.flink.table.client.gateway.local

Classes in org.apache.flink.table.client.gateway.local that implement StreamTableSink

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.

Uses of StreamTableSink in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories that return StreamTableSink

Modifier and Type	Method and Description
StreamTableSink<T>	StreamTableSinkFactory.createStreamTableSink(Map<String,String> properties) Creates and configures a StreamTableSink using the given properties.

Uses of StreamTableSink in org.apache.flink.table.sinks

Subinterfaces of StreamTableSink in org.apache.flink.table.sinks

Modifier and Type	Interface and Description
interface	AppendStreamTableSink<T> Defines an external TableSink to emit streaming Table with only insert changes.
interface	RetractStreamTableSink<T> Defines an external TableSink to emit a streaming Table with insert, update, and delete changes.
interface	UpsertStreamTableSink<T> Defines an external TableSink to emit a streaming Table with insert, update, and delete changes.

Classes in org.apache.flink.table.sinks that implement StreamTableSink

Modifier and Type	Class and Description
class	CsvTableSink A simple TableSink to emit data as CSV files.
class	OutputFormatTableSink<T> Defines an external TableSink to emit a bounded Table.

Methods in org.apache.flink.table.sinks that return StreamTableSink

Modifier and Type	Method and Description
StreamTableSink<Row>	CsvAppendTableSinkFactory.createStreamTableSink(Map<String,String> properties)