org.apache.flink.table.sinks

Class BatchSelectTableSink

java.lang.Object

org.apache.flink.table.sinks.BatchSelectTableSink

All Implemented Interfaces:

SelectTableSink, BatchTableSink<Row>, TableSink<Row>

public class BatchSelectTableSink
extends Object
implements BatchTableSink<Row>, SelectTableSink

A SelectTableSink for batch select job.

Constructor Summary

Constructors

Constructor and Description
BatchSelectTableSink(TableSchema tableSchema)

Method Summary

Modifier and Type	Method and Description
DataSink<?>	consumeDataSet(DataSet<Row> dataSet) Consumes the DataSet and return the DataSink.
DataType	getConsumedDataType() Returns the data type consumed by this TableSink.
CloseableIterator<Row>	getResultIterator() Returns the select result as row iterator.
TableSchema	getTableSchema() Returns the schema of the consumed table.
void	setJobClient(JobClient jobClient) Set the job client associated with the select job to retrieve the result.

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.api.internal.SelectTableSink

configure

Methods inherited from interface org.apache.flink.table.sinks.TableSink

getFieldNames, getFieldTypes, getOutputType

Constructor Detail

BatchSelectTableSink

public BatchSelectTableSink(TableSchema tableSchema)

Method Detail

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.

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>

setJobClient

public void setJobClient(JobClient jobClient)

Description copied from interface: SelectTableSink

Set the job client associated with the select job to retrieve the result.

Specified by:

setJobClient in interface SelectTableSink

getResultIterator

public CloseableIterator<Row> getResultIterator()

Description copied from interface: SelectTableSink

Returns the select result as row iterator.

Specified by:

getResultIterator in interface SelectTableSink