org.apache.flink.table.sinks

Class OutputFormatTableSink<T>

java.lang.Object

org.apache.flink.table.sinks.OutputFormatTableSink<T>

Type Parameters:

T - Type of the bounded OutputFormat that this TableSink expects and supports.

All Implemented Interfaces:

StreamTableSink<T>, TableSink<T>

Direct Known Subclasses:

CollectBatchTableSink

@Experimental
public abstract class OutputFormatTableSink<T>
extends Object
implements StreamTableSink<T>

Defines an external TableSink to emit a bounded Table.

Constructor Summary

Constructors

Constructor and Description
OutputFormatTableSink()

Method Summary

Modifier and Type	Method and Description
DataStreamSink<T>	consumeDataStream(DataStream<T> dataStream) Consumes the DataStream and return the sink transformation DataStreamSink.
abstract OutputFormat<T>	getOutputFormat() Returns an OutputFormat for writing the data of the table.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema

Constructor Detail

OutputFormatTableSink

public OutputFormatTableSink()

Method Detail

getOutputFormat

public abstract OutputFormat<T> getOutputFormat()

Returns an OutputFormat for writing the data of the table.

consumeDataStream

public final DataStreamSink<T> consumeDataStream(DataStream<T> dataStream)

Description copied from interface: StreamTableSink

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

Specified by:

consumeDataStream in interface StreamTableSink<T>