org.apache.flink.table.sinks

Interface StreamTableSink<T>

Type Parameters:

T - Type of the DataStream created by this TableSink.

All Superinterfaces:

TableSink<T>

All Known Subinterfaces:

AppendStreamTableSink<T>, RetractStreamTableSink<T>, UpsertStreamTableSink<T>

All Known Implementing Classes:

BatchSelectTableSink, CassandraAppendTableSink, CollectBatchTableSink, CollectStreamTableSink, CsvTableSink, Elasticsearch6UpsertTableSink, Elasticsearch7UpsertTableSink, ElasticsearchUpsertTableSinkBase, FileSystemTableSink, HBaseUpsertTableSink, HiveTableSink, JdbcUpsertTableSink, Kafka010TableSink, Kafka011TableSink, KafkaTableSink, KafkaTableSinkBase, OutputFormatTableSink, StreamSelectTableSink, StreamSelectTableSink

public interface StreamTableSink<T>
extends TableSink<T>

Defines an external stream table and provides write access to its data.

Method Summary

Modifier and Type	Method and Description
DataStreamSink<?>	consumeDataStream(DataStream<T> dataStream) Consumes the DataStream and return the sink transformation DataStreamSink.

Methods inherited from interface org.apache.flink.table.sinks.TableSink

configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema

Method Detail

consumeDataStream

DataStreamSink<?> consumeDataStream(DataStream<T> dataStream)

Consumes the DataStream and return the sink transformation DataStreamSink. The returned DataStreamSink will be used to set resources for the sink operator.