org.apache.flink.table.sinks

Interface AppendStreamTableSink<T>

Type Parameters:

T - Type of DataStream that this TableSink expects and supports.

All Superinterfaces:

StreamTableSink<T>, TableSink<T>

All Known Implementing Classes:

CassandraAppendTableSink, CsvTableSink, KafkaTableSink, KafkaTableSinkBase

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.

@Deprecated
 @PublicEvolving
public interface AppendStreamTableSink<T>
extends StreamTableSink<T>

Defines an external TableSink to emit streaming Table with only insert changes.

If the Table is also modified by update or delete changes, a TableException will be thrown.

Method Summary

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

consumeDataStream

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

configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema