AccountForMetadata registers the memory footprint of meta with the memory account and returns the total new memory usage.

BoolOrUnknownToSelOp plans an infrastructure necessary to convert a column of either Bool or Unknown type into a selection vector on the input batches.

EnsureSelectionVectorLength returns an int slice that is guaranteed to have the specified length.

HandleErrorFromDiskQueue takes in non-nil error emitted by colcontainer.Queue or colcontainer.PartitionedDiskQueue implementations and propagates it throughout the vectorized engine.

MakeWindowIntoBatch updates windowedBatch so that it provides a "window" into inputBatch that contains tuples in [startIdx, endIdx) range.

MaybeAllocateBoolArray makes sure that the passed in array is allocated, of the desired length and zeroed out.

MaybeAllocateLimitedBoolArray is an optimized version of maybeAllocateBool64Array that can *only* be used when length is at most coldata.MaxBatchSize.

MaybeAllocateLimitedUint32Array is an optimized version of MaybeAllocateUint32Array that can *only* be used when length is at most coldata.MaxBatchSize.

MaybeAllocateUint32Array makes sure that the passed in array is allocated, of the desired length and zeroed out.

NewAppendOnlyBufferedBatch returns a new AppendOnlyBufferedBatch that has initial zero capacity and could grow arbitrarily large with append() method.

NewBatchSchemaSubsetEnforcer creates a new BatchSchemaSubsetEnforcer.

NewBoolVecToSelOp is the operator form of BoolVecToSelOp.

NewCancelChecker creates a new CancelChecker.

NewDeselectorOp creates a new deselector operator on the given input operator with the given column types.

NewFixedNumTuplesNoInputOp creates a new Operator which returns batches with no actual columns that have specified number of tuples as the sum of their lengths.

NewRawColDataBatchOp allocates a rawBatchOp.

NewRewindableSpillingQueue creates a new SpillingQueue that can be rewinded in order to Dequeue all enqueued batches all over again.

NewSpillingBuffer creates a new SpillingBuffer.

NewSpillingQueue creates a new SpillingQueue.

NewVectorTypeEnforcer returns a new vectorTypeEnforcer.

NewZeroOp creates a new operator which just returns an empty batch.

UpdateBatchState updates batch to have the specified length and the selection vector.

DefaultSelectionVector contains all integers in [0, coldata.MaxBatchSize) range.

ZeroBoolColumn is zeroed out boolean slice of coldata.MaxBatchSize length.

ZeroUint32Column is zeroed out uint64 slice of coldata.MaxBatchSize length.

AppendOnlyBufferedBatch is a wrapper around coldata.Batch that should be used by operators that buffer many tuples into a single batch by appending to it.

BatchSchemaSubsetEnforcer is similar to vectorTypeEnforcer in its purpose, but it enforces that the subset of the columns of the non-zero length batch satisfies the desired schema.

BinaryOverloadHelper is a utility struct used for templates of the binary overloads that fall back to the row-based tree.Datum computation.

BoolVecToSelOp transforms a boolean column into a selection vector by adding an index to the selection for each true value in the boolean column.

CancelChecker is a colexecop.Operator that checks whether query cancellation has occurred.

Deserializer is a helper struct for deserializing columnar batches from the Apache Arrow format.

NewSpillingQueueArgs encompasses all necessary arguments to NewSpillingQueue.

SpillingBuffer wraps an AppendOnlyBufferedBatch to store tuples.

SpillingQueue is a Queue that uses a fixed-size in-memory circular buffer and spills to disk if the allocator reports that more memory than the caller-provided maxMemoryLimit is in use.