C
- cluster id to which this result belongs topublic class ChangelogCollectStreamResult<C> extends CollectStreamResult<C> implements ChangelogResult<C>
executionException, resultLock
clusterId, webInterfaceUrl
Constructor and Description |
---|
ChangelogCollectStreamResult(TypeInformation<Row> outputType,
ExecutionConfig config,
InetAddress gatewayAddress,
int gatewayPort) |
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) |
TypedResult<List<Tuple2<Boolean,Row>>> |
retrieveChanges()
Retrieves the available result records.
|
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 ChangelogCollectStreamResult(TypeInformation<Row> outputType, ExecutionConfig config, InetAddress gatewayAddress, int gatewayPort)
public boolean isMaterialized()
DynamicResult
isMaterialized
in interface DynamicResult<C>
public TypedResult<List<Tuple2<Boolean,Row>>> retrieveChanges()
ChangelogResult
retrieveChanges
in interface ChangelogResult<C>
protected void processRecord(Tuple2<Boolean,Row> change)
processRecord
in class CollectStreamResult<C>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.