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

Class CollectStreamTableSink

java.lang.Object

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

All Implemented Interfaces:

RetractStreamTableSink<Row>, StreamTableSink<Tuple2<Boolean,Row>>, TableSink<Tuple2<Boolean,Row>>

public class CollectStreamTableSink
extends Object
implements 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, TableSchema tableSchema)

Method Summary

Modifier and Type	Method and Description
CollectStreamTableSink	configure(String[] fieldNames, TypeInformation<?>[] fieldTypes) Returns a copy of this TableSink configured with the field names and types of the table to emit.
DataStreamSink<?>	consumeDataStream(DataStream<Tuple2<Boolean,Row>> stream) Consumes the DataStream and return the sink transformation DataStreamSink.
String[]	getFieldNames()
TypeInformation<?>[]	getFieldTypes()
TupleTypeInfo<Tuple2<Boolean,Row>>	getOutputType()
TypeInformation<Row>	getRecordType() Returns the requested record type.

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

getConsumedDataType, getTableSchema

Constructor Detail

CollectStreamTableSink

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

Method Detail

configure

public CollectStreamTableSink configure(String[] fieldNames,
                                        TypeInformation<?>[] fieldTypes)

Description copied from interface: TableSink

Returns a copy of this TableSink configured with the field names and types of the table to emit.

Specified by:

configure in interface TableSink<Tuple2<Boolean,Row>>

Parameters:

fieldNames - The field names of the table to emit.

fieldTypes - The field types of the table to emit.

Returns:

A copy of this TableSink configured with the field names and types of the table to emit.

getFieldNames

public String[] getFieldNames()

Specified by:

getFieldNames in interface TableSink<Tuple2<Boolean,Row>>

getFieldTypes

public TypeInformation<?>[] getFieldTypes()

Specified by:

getFieldTypes in interface TableSink<Tuple2<Boolean,Row>>

getRecordType

public TypeInformation<Row> getRecordType()

Description copied from interface: RetractStreamTableSink

Returns the requested record type.

Specified by:

getRecordType in interface RetractStreamTableSink<Row>

consumeDataStream

public DataStreamSink<?> consumeDataStream(DataStream<Tuple2<Boolean,Row>> stream)

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<Tuple2<Boolean,Row>>

getOutputType

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

Specified by:

getOutputType in interface RetractStreamTableSink<Row>

Specified by:

getOutputType in interface TableSink<Tuple2<Boolean,Row>>