public class MaterializedCollectBatchResult extends MaterializedCollectResultBase
CollectResultBase.ResultRetrievalThread
MATERIALIZED_TABLE_CAPACITY_FACTOR, MATERIALIZED_TABLE_MAX_INITIAL_CAPACITY, MATERIALIZED_TABLE_MAX_OVERCOMMIT, MATERIALIZED_TABLE_OVERCOMMIT_FACTOR, materializedTable, maxRowCount, overcommitThreshold, validRowPosition
executionException, resultLock, retrievalThread
Constructor and Description |
---|
MaterializedCollectBatchResult(TableResultInternal tableResult,
int maxRowCount) |
MaterializedCollectBatchResult(TableResultInternal tableResult,
int maxRowCount,
int overcommitThreshold) |
Modifier and Type | Method and Description |
---|---|
protected void |
processRecord(RowData row) |
computeMaterializedTableCapacity, computeMaterializedTableOvercommit, getMaterializedTable, isMaterialized, retrievePage, snapshot
close, handleMissingResult, isRetrieving
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
@VisibleForTesting public MaterializedCollectBatchResult(TableResultInternal tableResult, int maxRowCount, int overcommitThreshold)
public MaterializedCollectBatchResult(TableResultInternal tableResult, int maxRowCount)
protected void processRecord(RowData row)
processRecord
in class CollectResultBase
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.