org.apache.flink.table.api.internal

Interface SelectTableSink

All Superinterfaces:

TableSink<Row>

All Known Implementing Classes:

BatchSelectTableSink, BatchSelectTableSink, SelectTableSinkBase, StreamSelectTableSink, StreamSelectTableSink

@Internal
public interface SelectTableSink
extends TableSink<Row>

An internal special TableSink to collect the select query result to local client.

Method Summary

Modifier and Type	Method and Description
default TableSink<Row>	configure(String[] fieldNames, TypeInformation<?>[] fieldTypes) Returns a copy of this TableSink configured with the field names and types of the table to emit.
CloseableIterator<Row>	getResultIterator() Returns the select result as row iterator.
void	setJobClient(JobClient jobClient) Set the job client associated with the select job to retrieve the result.

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

getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema

Method Detail

configure

default TableSink<Row> 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.

setJobClient

void setJobClient(JobClient jobClient)

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

getResultIterator

CloseableIterator<Row> getResultIterator()

Returns the select result as row iterator.