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

Class MaterializedCollectBatchResult<C>

java.lang.Object

org.apache.flink.table.client.gateway.local.result.BasicResult<C>

org.apache.flink.table.client.gateway.local.result.MaterializedCollectBatchResult<C>

All Implemented Interfaces:

DynamicResult<C>, MaterializedResult<C>, Result<C>

public class MaterializedCollectBatchResult<C>
extends BasicResult<C>
implements MaterializedResult<C>

Collects results using accumulators and returns them as table snapshots.

Field Summary

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

clusterId, webInterfaceUrl

Constructor Summary

Constructors

Constructor and Description
MaterializedCollectBatchResult(TableSchema tableSchema, ExecutionConfig config, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the retrieval and all involved threads.
TableSink<?>	getTableSink() Returns the table sink required by this result type.
boolean	isMaterialized() Returns whether this result is materialized such that snapshots can be taken or results must be retrieved record-wise.
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.
void	startRetrieval(JobClient jobClient) Starts retrieving the result using the given JobClient and monitors it's execution.

Methods inherited from class org.apache.flink.table.client.gateway.local.result.BasicResult

getClusterId, getWebInterfaceUrl, setClusterInformation

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.result.Result

setClusterInformation

Constructor Detail

MaterializedCollectBatchResult

public MaterializedCollectBatchResult(TableSchema tableSchema,
                                      ExecutionConfig config,
                                      ClassLoader classLoader)

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>

startRetrieval

public void startRetrieval(JobClient jobClient)

Description copied from interface: DynamicResult

Starts retrieving the result using the given JobClient and monitors it's execution.

Specified by:

startRetrieval in interface DynamicResult<C>

getTableSink

public TableSink<?> getTableSink()

Description copied from interface: DynamicResult

Returns the table sink required by this result type.

Specified by:

getTableSink in interface DynamicResult<C>

close

public void close()

Description copied from interface: DynamicResult

Closes the retrieval and all involved threads.

Specified by:

close in interface DynamicResult<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>

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>