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

Class MaterializedCollectStreamResult<C>

java.lang.Object

org.apache.flink.table.client.gateway.local.CollectStreamResult<C>

org.apache.flink.table.client.gateway.local.MaterializedCollectStreamResult<C>

Type Parameters:

C - cluster id to which this result belongs to

All Implemented Interfaces:

DynamicResult<C>, MaterializedResult<C>

public class MaterializedCollectStreamResult<C>
extends CollectStreamResult<C>
implements MaterializedResult<C>

Collects results and returns them as table snapshots.

Field Summary

Fields inherited from class org.apache.flink.table.client.gateway.local.CollectStreamResult

executionException, resultLock

Constructor Summary

Constructors

Constructor and Description
MaterializedCollectStreamResult(TypeInformation<Row> outputType, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort)

Method Summary

Modifier and Type	Method and Description
boolean	isMaterialized() Returns whether this result is materialized such that snapshots can be taken or results must be retrieved record-wise.
protected void	processRecord(Tuple2<Boolean,Row> change)
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 class org.apache.flink.table.client.gateway.local.CollectStreamResult

close, getOutputType, getTableSink, handleMissingResult, isRetrieving, setClusterId, startRetrieval

Methods inherited from class java.lang.Object

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

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

close, getOutputType, getTableSink, setClusterId, startRetrieval

Constructor Detail

MaterializedCollectStreamResult

public MaterializedCollectStreamResult(TypeInformation<Row> outputType,
                                       ExecutionConfig config,
                                       InetAddress gatewayAddress,
                                       int gatewayPort)

Method Detail

isMaterialized

public boolean isMaterialized()

Description copied from interface: DynamicResult

Returns whether this result is materialized such that snapshots can be taken or results must be retrieved record-wise.

Specified by:

isMaterialized in interface DynamicResult<C>

snapshot

public TypedResult<Integer> snapshot(int pageSize)

Description copied from interface: MaterializedResult

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

Specified by:

snapshot in interface MaterializedResult<C>

retrievePage

public List<Row> retrievePage(int page)

Description copied from interface: MaterializedResult

Retrieves a page of a snapshotted result.

Specified by:

retrievePage in interface MaterializedResult<C>

processRecord

protected void processRecord(Tuple2<Boolean,Row> change)

Specified by:

processRecord in class CollectStreamResult<C>