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

Class CollectBatchTableSink

java.lang.Object

org.apache.flink.table.sinks.OutputFormatTableSink<Row>

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

All Implemented Interfaces:

BatchTableSink<Row>, StreamTableSink<Row>, TableSink<Row>

public class CollectBatchTableSink
extends OutputFormatTableSink<Row>
implements BatchTableSink<Row>

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

Constructor Summary

Constructors

Constructor and Description
CollectBatchTableSink(String accumulatorName, TypeSerializer<Row> serializer, TableSchema tableSchema)

Method Summary

Modifier and Type	Method and Description
CollectBatchTableSink	configure(String[] fieldNames, TypeInformation<?>[] fieldTypes) Returns a copy of this TableSink configured with the field names and types of the table to emit.
DataSink<?>	consumeDataSet(DataSet<Row> dataSet) Consumes the DataSet and return the DataSink.
DataType	getConsumedDataType() Returns the data type consumed by this TableSink.
OutputFormat<Row>	getOutputFormat() Returns an OutputFormat for writing the data of the table.
TypeSerializer<Row>	getSerializer() Returns the serializer for deserializing the collected result.
TableSchema	getTableSchema() Returns the schema of the consumed table.

Methods inherited from class org.apache.flink.table.sinks.OutputFormatTableSink

consumeDataStream

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

getFieldNames, getFieldTypes, getOutputType

Constructor Detail

CollectBatchTableSink

public CollectBatchTableSink(String accumulatorName,
                             TypeSerializer<Row> serializer,
                             TableSchema tableSchema)

Method Detail

getSerializer

public TypeSerializer<Row> getSerializer()

Returns the serializer for deserializing the collected result.

getConsumedDataType

public DataType getConsumedDataType()

Description copied from interface: TableSink

Returns the data type consumed by this TableSink.

Specified by:

getConsumedDataType in interface TableSink<Row>

Returns:

The data type expected by this TableSink.

getTableSchema

public TableSchema getTableSchema()

Description copied from interface: TableSink

Returns the schema of the consumed table.

Specified by:

getTableSchema in interface TableSink<Row>

Returns:

The TableSchema of the consumed table.

configure

public CollectBatchTableSink 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<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.

consumeDataSet

public DataSink<?> consumeDataSet(DataSet<Row> dataSet)

Description copied from interface: BatchTableSink

Consumes the DataSet and return the DataSink. The returned DataSink will be used to generate Plan.

Specified by:

consumeDataSet in interface BatchTableSink<Row>

getOutputFormat

public OutputFormat<Row> getOutputFormat()

Description copied from class: OutputFormatTableSink

Returns an OutputFormat for writing the data of the table.

Specified by:

getOutputFormat in class OutputFormatTableSink<Row>