Interface StreamTableSink<T>
-
- Type Parameters:
T
- Type of theDataStream
created by thisTableSink
.
- All Superinterfaces:
TableSink<T>
- All Known Subinterfaces:
AppendStreamTableSink<T>
,RetractStreamTableSink<T>
,UpsertStreamTableSink<T>
- All Known Implementing Classes:
CsvTableSink
,OutputFormatTableSink
@Deprecated @Internal public interface StreamTableSink<T> extends TableSink<T>
Deprecated.This interface has been replaced byDynamicTableSink
. The new interface consumes internal data structures. See FLIP-95 for more information.Defines an external stream table and provides write access to its data.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description DataStreamSink<?>
consumeDataStream(DataStream<T> dataStream)
Deprecated.Consumes the DataStream and return the sink transformationDataStreamSink
.-
Methods inherited from interface org.apache.flink.table.legacy.sinks.TableSink
configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema
-
-
-
-
Method Detail
-
consumeDataStream
DataStreamSink<?> consumeDataStream(DataStream<T> dataStream)
Deprecated.Consumes the DataStream and return the sink transformationDataStreamSink
. The returnedDataStreamSink
will be used to set resources for the sink operator.
-
-