public class MaterializedCollectBatchResult<C> extends BasicResult<C> implements MaterializedResult<C>
clusterId, webInterfaceUrl
Constructor and Description |
---|
MaterializedCollectBatchResult(TableSchema tableSchema,
RowTypeInfo outputType,
ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the retrieval and all involved threads.
|
TypeInformation<Row> |
getOutputType()
Returns the output type as defined by the query.
|
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(ProgramDeployer<C> deployer)
Starts the table program using the given deployer and monitors it's execution.
|
getClusterId, getWebInterfaceUrl, setClusterInformation
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setClusterInformation
public MaterializedCollectBatchResult(TableSchema tableSchema, RowTypeInfo outputType, ExecutionConfig config)
public boolean isMaterialized()
DynamicResult
isMaterialized
in interface DynamicResult<C>
public TypeInformation<Row> getOutputType()
DynamicResult
getOutputType
in interface DynamicResult<C>
public void startRetrieval(ProgramDeployer<C> deployer)
DynamicResult
startRetrieval
in interface DynamicResult<C>
public TableSink<?> getTableSink()
DynamicResult
getTableSink
in interface DynamicResult<C>
public void close()
DynamicResult
close
in interface DynamicResult<C>
public List<Row> retrievePage(int page)
MaterializedResult
retrievePage
in interface MaterializedResult<C>
public TypedResult<Integer> snapshot(int pageSize)
MaterializedResult
snapshot
in interface MaterializedResult<C>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.