public class ChangelogCollectResult extends CollectResultBase implements ChangelogResult
CollectResultBase.ResultRetrievalThread
Modifier and Type | Field and Description |
---|---|
protected static int |
CHANGE_RECORD_BUFFER_SIZE |
executionException, resultLock, retrievalThread
Constructor and Description |
---|
ChangelogCollectResult(TableResult tableResult) |
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(Row row) |
TypedResult<List<Row>> |
retrieveChanges()
Retrieves the available result records.
|
close, handleMissingResult, isRetrieving
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
@VisibleForTesting protected static final int CHANGE_RECORD_BUFFER_SIZE
public ChangelogCollectResult(TableResult tableResult)
public boolean isMaterialized()
DynamicResult
isMaterialized
in interface DynamicResult
public TypedResult<List<Row>> retrieveChanges()
ChangelogResult
retrieveChanges
in interface ChangelogResult
protected void processRecord(Row row)
processRecord
in class CollectResultBase
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.