org.apache.flink.table.client.gateway.local.result

Interface MaterializedResult<C>

Type Parameters:

C - cluster id to which this result belongs to

All Superinterfaces:

DynamicResult<C>, Result<C>

All Known Implementing Classes:

MaterializedCollectBatchResult, MaterializedCollectStreamResult

public interface MaterializedResult<C>
extends DynamicResult<C>

A result that is materialized and can be viewed by navigating through a snapshot.

Method Summary

Modifier and Type	Method and Description
List<Row>	retrievePage(int page) Retrieves a page of a snapshotted result.
TypedResult<Integer>	snapshot(int pageSize) Takes a snapshot of the current table and returns the number of pages for navigating through the snapshot.

Methods inherited from interface org.apache.flink.table.client.gateway.local.result.DynamicResult

close, getTableSink, isMaterialized, startRetrieval

Methods inherited from interface org.apache.flink.table.client.gateway.local.result.Result

setClusterInformation

Method Detail

snapshot

TypedResult<Integer> snapshot(int pageSize)

Takes a snapshot of the current table and returns the number of pages for navigating through the snapshot.

retrievePage

List<Row> retrievePage(int page)

Retrieves a page of a snapshotted result.