org.apache.flink.table.planner.sinks

Class StreamSelectTableSink

java.lang.Object

org.apache.flink.table.planner.sinks.SelectTableSinkBase

org.apache.flink.table.planner.sinks.StreamSelectTableSink

All Implemented Interfaces:

SelectTableSink, AppendStreamTableSink<Row>, StreamTableSink<Row>, TableSink<Row>

public class StreamSelectTableSink
extends SelectTableSinkBase
implements AppendStreamTableSink<Row>

A SelectTableSink for streaming select job.

NOTE: Currently, only insert changes (AppendStreamTableSink) is supported. Once FLINK-16998 is finished, all kinds of changes will be supported.

Constructor Summary

Constructors

Constructor and Description
StreamSelectTableSink(TableSchema tableSchema)

Method Summary

Modifier and Type	Method and Description
DataStreamSink<?>	consumeDataStream(DataStream<Row> dataStream) Consumes the DataStream and return the sink transformation DataStreamSink.

Methods inherited from class org.apache.flink.table.planner.sinks.SelectTableSinkBase

getConsumedDataType, getResultIterator, getTableSchema, setJobClient

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

Methods inherited from interface org.apache.flink.table.api.internal.SelectTableSink

configure

Constructor Detail

StreamSelectTableSink

public StreamSelectTableSink(TableSchema tableSchema)

Method Detail

consumeDataStream

public DataStreamSink<?> consumeDataStream(DataStream<Row> 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<Row>

Overrides:

consumeDataStream in class SelectTableSinkBase