Package org.apache.flink.table.gateway.service.result

Class ResultStore

java.lang.Object

org.apache.flink.table.gateway.service.result.ResultStore

public class ResultStore
extends Object

A result store which stores and buffers results.

Field Summary

Fields

Modifier and Type	Field	Description
static ResultStore	DUMMY_RESULT_STORE

Constructor Summary

Constructors

Constructor	Description
ResultStore(org.apache.flink.util.CloseableIterator<org.apache.flink.table.data.RowData> result, int maxBufferSize)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getBufferedRecordSize()
boolean	isRetrieving()
Optional<List<org.apache.flink.table.data.RowData>>	retrieveRecords()
void	waitUntilHasData()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DUMMY_RESULT_STORE

public static final ResultStore DUMMY_RESULT_STORE

Constructor Detail

ResultStore

public ResultStore(org.apache.flink.util.CloseableIterator<org.apache.flink.table.data.RowData> result,
                   int maxBufferSize)

Method Detail

close

public void close()

retrieveRecords

public Optional<List<org.apache.flink.table.data.RowData>> retrieveRecords()

getBufferedRecordSize

public int getBufferedRecordSize()

waitUntilHasData

public void waitUntilHasData()

isRetrieving

public boolean isRetrieving()