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(StatementResult tableResult) |
Modifier and Type | Method and Description |
---|---|
protected void |
processRecord(RowData row) |
TypedResult<List<RowData>> |
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(StatementResult tableResult)
public TypedResult<List<RowData>> retrieveChanges()
ChangelogResult
retrieveChanges
in interface ChangelogResult
protected void processRecord(RowData row)
processRecord
in class CollectResultBase
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.