Package colexeccmp exposes some comparison definitions for vectorized operations.

Package colexecspan implements utilities for manipulating spans.

EncDatumRowToColVecs converts the provided rowenc.EncDatumRow to the columnar format and writes the converted values at the rowIdx position of the given vecs.

MaybeUnwrapInvariantsChecker checks whether op is an invariants checker and returns its input if so, otherwise op is returned.

NewBufferingColumnarizer returns a new Columnarizer that will be buffering up rows before emitting them as output batches.

NewBufferingColumnarizerForTests is a convenience wrapper around NewBufferingColumnarizer to be used in tests (when we don't care about the memory accounting).

NewBufferOp returns a new bufferOp, initialized to buffer batches from the supplied input.

NewBuiltinFunctionOperator returns an operator that applies builtin functions.

NewCaseOp returns an operator that runs a case statement.

NewCountOp returns a new count operator that counts the rows in its input.

NewHashAggregator creates a hash aggregator on the given grouping columns.

NewHashGroupJoiner creates a new hash group-join operator.

NewInsertOp allocates a new vector insert operator.

NewInvariantsChecker creates a new invariantsChecker.

NewIsNullProjOp returns a new isNullProjOp.

NewIsNullSelOp returns a new isNullSelOp.

NewLimitOp returns a new limit operator with the given limit.

NewMaterializer creates a new Materializer processor which processes the columnar data coming from input to return it as rows.

NewNotExprProjOp returns a new notExprProjOp if the underlying type family of the input expression is boolean.

NewNotExprSelOp returns a new notExprSelOp if the underlying type family of the input expression is boolean.

NewOffsetOp returns a new offset operator with the given offset.

NewOrderedAggregator creates an ordered aggregator.

NewOrderedSynchronizer creates a new OrderedSynchronizer.

NewParallelUnorderedSynchronizer creates a new ParallelUnorderedSynchronizer.

NewSerialUnorderedSynchronizer creates a new SerialUnorderedSynchronizer.

NewSortChunks returns a new sort chunks operator, which sorts its input on the columns given in orderingCols.

NewSorter returns a new sort operator, which sorts its input on the columns given in orderingCols.

NewStreamingColumnarizer returns a new Columnarizer that emits every input row as a separate batch.

NewTopKSorter returns a new sort operator, which sorts its input on the columns given in orderingCols and returns the first K rows.

NewTupleProjOp creates a new tupleProjOp that projects newly-created tuples at position outputIdx taking the tuples' contents from corresponding values of the vectors at positions tupleContentsIdxs.

NewUnorderedDistinct creates an unordered distinct on the given distinct columns.

NewValuesOp returns a new values operator, which has no input and outputs a fixed set of rows.

HashAggregationDiskSpillingEnabledSettingName is the cluster setting name for HashAggregationDiskSpillingEnabled.

VecMaxOpenFDsLimit specifies the maximum number of open file descriptors that the vectorized engine can have (globally) for use of the temporary storage.

HashAggregationDiskSpillingEnabled is a cluster setting that allows to disable hash aggregator disk spilling.

Columnarizer turns an execinfra.RowSource input into an Operator output, by reading the input in chunks of size coldata.BatchSize() and converting each chunk into a coldata.Batch column by column.

Materializer converts an Operator input into a execinfra.RowSource.

OrderedSynchronizer receives rows from multiple inputs and produces a single stream of rows, ordered according to a set of columns.

ParallelUnorderedSynchronizer is an Operator that combines multiple Operator streams into one.

SerialUnorderedSynchronizer is an Operator that combines multiple Operator streams into one.

UnorderedDistinct performs a DISTINCT operation using a HashTable.