org.apache.flink.table.api.internal

Interface ResultProvider

All Known Implementing Classes:

StaticResultProvider

@Internal
public interface ResultProvider

An internal class which helps the client to get the execute result from a specific sink.

The two iterators are exclusive, that is you can use only one of the two at the same time.

This class is generated by specific sink and brings the result info to a TableResult.

Method Summary

Modifier and Type	Method and Description
RowDataToStringConverter	getRowDataStringConverter()
boolean	isFirstRowReady() Return true if the first row is ready.
ResultProvider	setJobClient(JobClient jobClient) Set the job client associated with the select job to retrieve the result.
CloseableIterator<Row>	toExternalIterator() Returns the select result as row iterator using external data types.
CloseableIterator<RowData>	toInternalIterator() Returns the select result as row iterator using internal data types.

Method Detail

setJobClient

ResultProvider setJobClient(JobClient jobClient)

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

toInternalIterator

CloseableIterator<RowData> toInternalIterator()

Returns the select result as row iterator using internal data types. You must not invoke this method after invoking toExternalIterator().

toExternalIterator

CloseableIterator<Row> toExternalIterator()

Returns the select result as row iterator using external data types. You must not invoke this method after invoking toInternalIterator().

getRowDataStringConverter

RowDataToStringConverter getRowDataStringConverter()

isFirstRowReady

boolean isFirstRowReady()

Return true if the first row is ready.

The first row is ready when Iterator.hasNext() method returns true or Iterator.next() method returns a row.