org.apache.flink.table.client.gateway.local

Class CollectStreamTableSink

java.lang.Object

org.apache.flink.table.client.gateway.local.CollectStreamTableSink

All Implemented Interfaces:

org.apache.flink.table.sinks.RetractStreamTableSink<Row>, org.apache.flink.table.sinks.TableSink<Tuple2<Boolean,Row>>

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

Table sink for collecting the results locally using sockets.

Constructor Summary

Constructors

Constructor and Description
CollectStreamTableSink(InetAddress targetAddress, int targetPort, TypeSerializer<Tuple2<Boolean,Row>> serializer)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.sinks.TableSink<Tuple2<Boolean,Row>>	configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
void	emitDataStream(DataStream<Tuple2<Boolean,Row>> stream)
String[]	getFieldNames()
TypeInformation<?>[]	getFieldTypes()
TupleTypeInfo<Tuple2<Boolean,Row>>	getOutputType()
TypeInformation<Row>	getRecordType()

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectStreamTableSink

public CollectStreamTableSink(InetAddress targetAddress,
                              int targetPort,
                              TypeSerializer<Tuple2<Boolean,Row>> serializer)

Method Detail

getFieldNames

public String[] getFieldNames()

Specified by:

getFieldNames in interface org.apache.flink.table.sinks.TableSink<Tuple2<Boolean,Row>>

getFieldTypes

public TypeInformation<?>[] getFieldTypes()

Specified by:

getFieldTypes in interface org.apache.flink.table.sinks.TableSink<Tuple2<Boolean,Row>>

configure

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

Specified by:

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

getRecordType

public TypeInformation<Row> getRecordType()

Specified by:

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

emitDataStream

public void emitDataStream(DataStream<Tuple2<Boolean,Row>> stream)

Specified by:

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

getOutputType

public TupleTypeInfo<Tuple2<Boolean,Row>> getOutputType()

Specified by:

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

Specified by:

getOutputType in interface org.apache.flink.table.sinks.TableSink<Tuple2<Boolean,Row>>