CompareEncDatumRowForMerge EncDatumRow compares two EncDatumRows for merging.

CreateWindowerSpecFunc creates a WindowerSpec_Func based on the function name or returns an error if unknown function name is provided.

GetResumeSpans returns a ResumeSpanList from a job.

GetWindowFunctionInfo returns windowFunc constructor and the return type when given fn is applied to given inputTypes.

NewDistinct instantiates a new Distinct processor.

NewProcessor creates a new execinfra.Processor according to the provided core.

SetResumeSpansInJob adds a list of resume spans into a job details field.

WriteResumeSpan writes a checkpoint for the backfill work on origSpan.

SubqueryExecModeAllRows indicates that the subquery is an argument to an ARRAY constructor.

SubqueryExecModeAllRowsNormalized indicates that the subquery is an argument to IN, ANY, SOME, or ALL.

SubqueryExecModeExists indicates that the subquery is an argument to EXISTS.

SubqueryExecModeOneRow indicates that the subquery is an argument to another function.

SubqueryExecModeUnknown is the default value, and is only used to indicate a subquery that was improperly initialized.

CTASPlanResultTypes is the result types for EXPORT plans.

NewChangeAggregatorProcessor is externally implemented.

NewChangeFrontierProcessor is externally implemented.

NewCSVWriterProcessor is externally implemented.

NewReadImportDataProcessor is externally implemented and registered by ccl/sqlccl/csv.go.

NewSSTWriterProcessor is externally implemented and registered by ccl/sqlccl/csv.go.

SampleAggregatorProgressInterval is the frequency at which the SampleAggregator processor will report progress.

SamplerProgressInterval corresponds to the number of input rows after which the sampler will report progress by pushing a metadata record.

ScrubTypes is the schema for TableReaders that are doing a SCRUB check.

SubqueryExecModeNames maps SubqueryExecMode values to human readable strings for EXPLAIN queries.

TestingSamplerSleep introduces a sleep inside the sampler, every <samplerProgressInterval>.

AggregatorStats are the stats collected during an aggregator run.

Distinct is the physical processor implementation of the DISTINCT relational operator.

DistinctStats are the stats collected during a distinct run.

HashJoinerStats are the stats collected during a hashJoiner run.

MergeJoinerStats are the stats collected during a mergeJoiner run.

OrdinalityStats are the stats collected during a WITH ORDINALITY run.

SortedDistinct is a specialized distinct that can be used when all of the distinct columns are also ordered.

SorterStats are the stats collected during a sorter run.

TableReaderStats are the stats collected during a tableReader run.

WindowerStats are the stats collected during a windower run.

VectorizeAlwaysException is an object that returns whether or not execution should continue if vectorize=experimental_always and an error occurred when setting up the vectorized flow.

SubqueryExecMode is an enum to indicate the type of a subquery.