MCPcopy Create free account
hub / github.com/apache/impala / AtCapacity

Method AtCapacity

be/src/runtime/row-batch.h:153–161  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

151 /// enough memory. The memory calculation includes the tuple data pool and any
152 /// auxiliary memory attached to the row batch.
153 bool ALWAYS_INLINE AtCapacity() {
154 DCHECK_LE(num_rows_, capacity_);
155 // Check AtCapacity() condition enforced in MarkNeedsDeepCopy() and
156 // MarkFlushResources().
157 DCHECK((!needs_deep_copy_ && flush_mode_ == FlushMode::NO_FLUSH_RESOURCES)
158 || num_rows_ == capacity_);
159 int64_t mem_usage = attached_buffer_bytes_ + tuple_data_pool_.total_reserved_bytes();
160 return num_rows_ == capacity_ || mem_usage >= AT_CAPACITY_MEM_USAGE;
161 }
162
163 TupleRow* ALWAYS_INLINE GetRow(int row_idx) {
164 DCHECK(tuple_ptrs_ != nullptr);

Callers 15

ProcessProbeBatchMethod · 0.45
GetNextOutputBatchMethod · 0.45
MaterializeExprsMethod · 0.45
GetNextUnpartitionedMethod · 0.45
GetNextPartitionedMethod · 0.45
EvictPartitionsMethod · 0.45
AddBatchStreamingImplMethod · 0.45
FOREACH_ROW_LIMITFunction · 0.45
GetNextMethod · 0.45
GetNextMethod · 0.45
GetNextMethod · 0.45
GetNextMethod · 0.45

Calls 1

total_reserved_bytesMethod · 0.80

Tested by 2

TestTransferMemoryMethod · 0.36
TestAttachMemoryMethod · 0.36