CatchVectorizedRuntimeError executes operation, catches a runtime error if it is coming from the vectorized engine, and returns it.

EstimateBatchSizeBytes returns an estimated amount of bytes needed to store a batch in memory that has column types vecTypes.

GetLikeOperator returns a selection operator which applies the specified LIKE pattern, or NOT LIKE if the negate argument is true.

NewBatchBuffer creates a new BatchBuffer.

NewBoolVecToSelOp is the operator form of boolVecToSelOp.

NewBuiltinFunctionOperator returns an operator that applies builtin functions.

NewCancelChecker creates a new CancelChecker.

NewCoalescerOp creates a new coalescer operator on the given input operator with the given column types.

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

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

NewEqHashJoinerOp creates a new equality hash join operator on the left and right input tables.

NewHashAggregator creates a hash aggregator on the given grouping columns.

NewHashRouter creates a new hash router that consumes coldata.Batches from input and hashes each row according to hashCols to one of numOutputs outputs.

NewLimitOp returns a new limit operator with the given limit.

NewMergeJoinOp returns a new merge join operator with the given spec that implements sort-merge join.

NewNoop returns a new noop Operator.

NewOffsetOp returns a new offset operator with the given offset.

NewOrderedAggregator creates an ordered aggregator on the given grouping columns.

NewOrderedSynchronizer creates a new OrderedSynchronizer.

NewOrdinalityOp returns a new WITH ORDINALITY operator.

NewRandomDataOp creates a new RandomDataOp.

NewRepeatableBatchSource returns a new Operator initialized to return its input batch forever (including the selection vector if batch comes with it).

NewSimpleProjectOp returns a new simpleProjectOp that applies a simple projection on the columns in its input batch, returning a new batch with only the columns in the projection slice, in order.

NewSingleTupleNoInputOp creates a new Operator which returns a batch of length 1 with no actual columns on the first call to Next() and zero-length batches on all consecutive calls.

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.

NewStorageError returns a new storage error.

NewTestVectorizedErrorEmitter creates a new TestVectorizedErrorEmitter.

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

NewUnorderedSynchronizer creates a new UnorderedSynchronizer.

NewVectorizedStatsCollector creates a new VectorizedStatsCollector which wraps op that corresponds to a processor with ProcessorID id.

NewWindowSortingPartitioner creates a new exec.Operator that orders input first based on the partitionIdxs columns and second on ordCols (i.e.

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

PhysicalTypeColElemToDatum converts an element in a colvec to a datum of semtype ct.

RandomBatch returns an n-length batch of the given typs where each value will be null with a probability of nullProbability.

BatchBuffer exposes a buffer of coldata.Batches through an Operator interface.

CancelChecker is an Operator that checks whether query cancellation has occurred.

HashRouter hashes values according to provided hash columns and computes a destination for each row.

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

RandomDataOp is an operator that generates random data according to RandomDataOpArgs.

RandomDataOpArgs are arguments passed in to RandomDataOp.

RepeatableBatchSource is an Operator that returns the same batch forever.

StorageError is an error that was created by a component below the sql stack, such as the network or storage layers.

TestVectorizedErrorEmitter is an Operator that panics on every odd-numbered invocation of Next() and returns the next batch from the input on every even-numbered (i.e.

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

VectorizedStatsCollector collects VectorizedStats on Operators.

Operator is a column vector operator that produces a Batch as output.

StaticMemoryOperator is an interface that streaming operators can implement if they are able to declare their memory usage upfront.