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

Class CollectBatchTableSink

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.table.sinks.BatchTableSink<org.apache.flink.types.Row>, org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

public class CollectBatchTableSink
extends Object
implements org.apache.flink.table.sinks.BatchTableSink<org.apache.flink.types.Row>

Table sink for collecting the results locally all at once using accumulators.

Constructor Summary

Constructors

Constructor and Description
CollectBatchTableSink(String accumulatorName, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row> serializer)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>	configure(String[] fieldNames, org.apache.flink.api.common.typeinfo.TypeInformation<?>[] fieldTypes)
void	emitDataSet(org.apache.flink.api.java.DataSet<org.apache.flink.types.Row> dataSet)
String[]	getFieldNames()
org.apache.flink.api.common.typeinfo.TypeInformation<?>[]	getFieldTypes()
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row>	getOutputType()
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row>	getSerializer() Returns the serializer for deserializing the collected result.

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectBatchTableSink

public CollectBatchTableSink(String accumulatorName,
                             org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row> serializer)

Method Detail

getOutputType

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

Specified by:

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

getFieldNames

public String[] getFieldNames()

Specified by:

getFieldNames in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

getFieldTypes

public org.apache.flink.api.common.typeinfo.TypeInformation<?>[] getFieldTypes()

Specified by:

getFieldTypes in interface org.apache.flink.table.sinks.TableSink<org.apache.flink.types.Row>

configure

public org.apache.flink.table.sinks.TableSink<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.types.Row>

emitDataSet

public void emitDataSet(org.apache.flink.api.java.DataSet<org.apache.flink.types.Row> dataSet)

Specified by:

emitDataSet in interface org.apache.flink.table.sinks.BatchTableSink<org.apache.flink.types.Row>

getSerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.types.Row> getSerializer()

Returns the serializer for deserializing the collected result.