T
- Type of the bounded OutputFormat
that this TableSink
expects and supports.@Experimental public abstract class OutputFormatTableSink<T> extends Object implements StreamTableSink<T>
Constructor and Description |
---|
OutputFormatTableSink() |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
consumeDataStream(DataStream<T> dataStream)
Consumes the DataStream and return the sink transformation
DataStreamSink . |
void |
emitDataStream(DataStream<T> dataStream)
Emits the DataStream.
|
abstract OutputFormat<T> |
getOutputFormat()
Returns an
OutputFormat for writing the data of the table. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema
public abstract OutputFormat<T> getOutputFormat()
OutputFormat
for writing the data of the table.public final void emitDataStream(DataStream<T> dataStream)
StreamTableSink
emitDataStream
in interface StreamTableSink<T>
public final DataStreamSink<T> consumeDataStream(DataStream<T> dataStream)
StreamTableSink
DataStreamSink
.
The returned DataStreamSink
will be used to set resources for the sink operator.consumeDataStream
in interface StreamTableSink<T>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.