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:

CsvTableSink, OutputFormatTableSink

Deprecated.

This interface has been replaced by DynamicTableSink. The new interface consumes internal data structures. See FLIP-95 for more information.

@Deprecated
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) Deprecated. 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)

Deprecated.

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