C
- cluster id to which this result belongs topublic class MaterializedCollectStreamResult<C> extends CollectStreamResult<C> implements MaterializedResult<C>
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.
|
executionException, resultLock
clusterId, webInterfaceUrl
Constructor and Description |
---|
MaterializedCollectStreamResult(TypeInformation<Row> outputType,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort,
int maxRowCount) |
MaterializedCollectStreamResult(TypeInformation<Row> outputType,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort,
int maxRowCount,
int overcommitThreshold) |
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.
|
close, getOutputType, getTableSink, handleMissingResult, isRetrieving, startRetrieval
getClusterId, getWebInterfaceUrl, setClusterInformation
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getOutputType, getTableSink, startRetrieval
setClusterInformation
public static final int MATERIALIZED_TABLE_MAX_INITIAL_CAPACITY
public static final int MATERIALIZED_TABLE_MAX_OVERCOMMIT
public static final double MATERIALIZED_TABLE_CAPACITY_FACTOR
public static final double MATERIALIZED_TABLE_OVERCOMMIT_FACTOR
@VisibleForTesting public MaterializedCollectStreamResult(TypeInformation<Row> outputType, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort, int maxRowCount, int overcommitThreshold)
public MaterializedCollectStreamResult(TypeInformation<Row> outputType, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort, int maxRowCount)
public boolean isMaterialized()
DynamicResult
isMaterialized
in interface DynamicResult<C>
public TypedResult<Integer> snapshot(int pageSize)
MaterializedResult
snapshot
in interface MaterializedResult<C>
public List<Row> retrievePage(int page)
MaterializedResult
retrievePage
in interface MaterializedResult<C>
protected void processRecord(Tuple2<Boolean,Row> change)
processRecord
in class CollectStreamResult<C>
@VisibleForTesting protected List<Row> getMaterializedTable()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.