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 and Description
static ResultStore	DUMMY_RESULT_STORE

Constructor Summary

Constructors

Constructor and Description
ResultStore(CloseableIterator<RowData> result, int maxBufferSize)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getBufferedRecordSize()
boolean	isRetrieving()
Optional<List<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(CloseableIterator<RowData> result,
                   int maxBufferSize)

Method Detail

close

public void close()

retrieveRecords

public Optional<List<RowData>> retrieveRecords()

getBufferedRecordSize

public int getBufferedRecordSize()

waitUntilHasData

public void waitUntilHasData()

isRetrieving

public boolean isRetrieving()