org.apache.flink.table.sinks

Class BatchSelectTableSink

java.lang.Object

org.apache.flink.table.sinks.BatchSelectTableSink

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 BatchSelectTableSink
extends Object
implements org.apache.flink.table.sinks.BatchTableSink<org.apache.flink.types.Row>

A BatchTableSink for batch select job to collect the result to local.

Constructor Summary

Constructors

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

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)
org.apache.flink.api.java.operators.DataSink<?>	consumeDataSet(org.apache.flink.api.java.DataSet<org.apache.flink.types.Row> dataSet)
org.apache.flink.table.types.DataType	getConsumedDataType()
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.TableSink

getFieldNames, getFieldTypes, getOutputType

Constructor Detail

BatchSelectTableSink

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

Method Detail

getConsumedDataType

public org.apache.flink.table.types.DataType getConsumedDataType()

Specified by:

getConsumedDataType in interface org.apache.flink.table.sinks.TableSink<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.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>

consumeDataSet

public org.apache.flink.api.java.operators.DataSink<?> consumeDataSet(org.apache.flink.api.java.DataSet<org.apache.flink.types.Row> dataSet)

Specified by:

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

getSelectResultProvider

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