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

Class MaterializedCollectStreamResult<C>

java.lang.Object

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

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

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

Type Parameters:

C - cluster id to which this result belongs to

All Implemented Interfaces:

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

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

Collects results and returns them as table snapshots.

Field Summary

Fields

Modifier and Type	Field and Description
static double	MATERIALIZED_TABLE_CAPACITY_FACTOR Factor for the initial capacity of the materialized table.
static int	MATERIALIZED_TABLE_MAX_INITIAL_CAPACITY Maximum initial capacity of the materialized table.
static int	MATERIALIZED_TABLE_MAX_OVERCOMMIT Maximum overcommitment of the materialized table.
static double	MATERIALIZED_TABLE_OVERCOMMIT_FACTOR Factor for cleaning up deleted rows in the materialized table.

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

executionException, resultLock

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

clusterId, webInterfaceUrl

Constructor Summary

Constructors

Constructor and Description
MaterializedCollectStreamResult(TableSchema tableSchema, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort, int maxRowCount, ClassLoader classLoader)
MaterializedCollectStreamResult(TableSchema tableSchema, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort, int maxRowCount, int overcommitThreshold, ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
protected List<Row>	getMaterializedTable()
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.result.CollectStreamResult

close, getTableSink, handleMissingResult, isRetrieving, startRetrieval

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.DynamicResult

close, getTableSink, startRetrieval

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

setClusterInformation

Field Detail

MATERIALIZED_TABLE_MAX_INITIAL_CAPACITY

public static final int MATERIALIZED_TABLE_MAX_INITIAL_CAPACITY

Maximum initial capacity of the materialized table.

See Also:

Constant Field Values

MATERIALIZED_TABLE_MAX_OVERCOMMIT

public static final int MATERIALIZED_TABLE_MAX_OVERCOMMIT

Maximum overcommitment of the materialized table.

See Also:

Constant Field Values

MATERIALIZED_TABLE_CAPACITY_FACTOR

public static final double MATERIALIZED_TABLE_CAPACITY_FACTOR

Factor for the initial capacity of the materialized table.

See Also:

Constant Field Values

MATERIALIZED_TABLE_OVERCOMMIT_FACTOR

public static final double MATERIALIZED_TABLE_OVERCOMMIT_FACTOR

Factor for cleaning up deleted rows in the materialized table.

See Also:

Constant Field Values

Constructor Detail

MaterializedCollectStreamResult

@VisibleForTesting
public MaterializedCollectStreamResult(TableSchema tableSchema,
                                                          ExecutionConfig config,
                                                          InetAddress gatewayAddress,
                                                          int gatewayPort,
                                                          int maxRowCount,
                                                          int overcommitThreshold,
                                                          ClassLoader classLoader)

MaterializedCollectStreamResult

public MaterializedCollectStreamResult(TableSchema tableSchema,
                                       ExecutionConfig config,
                                       InetAddress gatewayAddress,
                                       int gatewayPort,
                                       int maxRowCount,
                                       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>

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>

getMaterializedTable

@VisibleForTesting
protected List<Row> getMaterializedTable()