org.apache.flink.table.sinks

Class StreamSelectTableSink

java.lang.Object

org.apache.flink.table.sinks.StreamSelectTableSink

All Implemented Interfaces:

org.apache.flink.table.sinks.RetractStreamTableSink<org.apache.flink.types.Row>, org.apache.flink.table.sinks.StreamTableSink<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>>, org.apache.flink.table.sinks.TableSink<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>>

public class StreamSelectTableSink
extends Object
implements org.apache.flink.table.sinks.RetractStreamTableSink<org.apache.flink.types.Row>

A RetractStreamTableSink for streaming select job to collect the result to local.

Constructor Summary

Constructors

Constructor and Description
StreamSelectTableSink(org.apache.flink.table.api.TableSchema tableSchema)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.sinks.TableSink<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>>	configure(String[] fieldNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>> dataStream)
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row>	getRecordType()
org.apache.flink.table.api.internal.CollectResultProvider	getSelectResultProvider()
org.apache.flink.table.api.TableSchema	getTableSchema()

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.RetractStreamTableSink

getOutputType

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

getConsumedDataType, getFieldNames, getFieldTypes

Constructor Detail

StreamSelectTableSink

public StreamSelectTableSink(org.apache.flink.table.api.TableSchema tableSchema)

Method Detail

getRecordType

public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> getRecordType()

Specified by:

getRecordType in interface org.apache.flink.table.sinks.RetractStreamTableSink<org.apache.flink.types.Row>

getTableSchema

public org.apache.flink.table.api.TableSchema getTableSchema()

Specified by:

getTableSchema in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>>

configure

public org.apache.flink.table.sinks.TableSink<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>> configure(String[] fieldNames,
                                                                                                                                    org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)

Specified by:

configure in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>>

consumeDataStream

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> consumeDataStream(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>> dataStream)

Specified by:

consumeDataStream in interface org.apache.flink.table.sinks.StreamTableSink<org.apache.flink.api.java.tuple.Tuple2<Boolean,org.apache.flink.types.Row>>

getSelectResultProvider

public org.apache.flink.table.api.internal.CollectResultProvider getSelectResultProvider()