T
- Type of the DataStream
created by this TableSink
.public interface StreamTableSink<T> extends TableSink<T>
Modifier and Type | Method and Description |
---|---|
default DataStreamSink<?> |
consumeDataStream(DataStream<T> dataStream)
Consumes the DataStream and return the sink transformation
DataStreamSink . |
void |
emitDataStream(DataStream<T> dataStream)
Deprecated.
This method will be removed in future versions as it returns nothing.
It is recommended to use
consumeDataStream(DataStream) instead which
returns the DataStreamSink . The returned DataStreamSink will be
used to set resources for the sink operator. If the consumeDataStream(DataStream)
is implemented, this method can be empty implementation. |
configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema
@Deprecated void emitDataStream(DataStream<T> dataStream)
consumeDataStream(DataStream)
instead which
returns the DataStreamSink
. The returned DataStreamSink
will be
used to set resources for the sink operator. If the consumeDataStream(DataStream)
is implemented, this method can be empty implementation.default DataStreamSink<?> consumeDataStream(DataStream<T> dataStream)
DataStreamSink
.
The returned DataStreamSink
will be used to set resources for the sink operator.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.