public abstract class CollectResultBase extends Object implements DynamicResult
TableResult.collect()
.Modifier and Type | Class and Description |
---|---|
protected class |
CollectResultBase.ResultRetrievalThread
Thread to retrieve data from the
CloseableIterator and process. |
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<SqlExecutionException> |
executionException |
protected Object |
resultLock |
protected CollectResultBase.ResultRetrievalThread |
retrievalThread |
Constructor and Description |
---|
CollectResultBase(TableResultInternal tableResult) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the retrieval and all involved threads.
|
protected <T> TypedResult<T> |
handleMissingResult() |
protected boolean |
isRetrieving() |
protected abstract void |
processRecord(RowData row) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isMaterialized
protected final Object resultLock
protected AtomicReference<SqlExecutionException> executionException
protected final CollectResultBase.ResultRetrievalThread retrievalThread
public CollectResultBase(TableResultInternal tableResult)
public void close() throws Exception
DynamicResult
close
in interface DynamicResult
Exception
protected <T> TypedResult<T> handleMissingResult()
protected abstract void processRecord(RowData row)
protected boolean isRetrieving()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.