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.

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

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

TestingSetScannedRowProgressFrequency changes the frequency at which row-scanned progress metadata is emitted by table readers.

WriteResumeSpan writes a checkpoint for the backfill work on origSpan.

MaxDiskQueryPlanSuffix is the tag suffix for the max disk used.

MaxDiskTagSuffix is the tag suffix for the max disk used stat.

MaxMemoryQueryPlanSuffix is the tag suffix for the max memory used.

MaxMemoryTagSuffix is the tag suffix for the max memory used stat.

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.

CTASPlanResultTypes is the result types for EXPORT plans.

NewBackupDataProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

NewChangeAggregatorProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

NewChangeFrontierProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

NewCSVWriterProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

NewReadImportDataProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

NewRestoreDataProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

NewSplitAndScatterProcessor is implemented in the non-free (CCL) codebase and then injected here via runtime initialization.

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.

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

AggregatorStats are the stats collected during an aggregator run.

DistinctStats are the stats collected during a distinct run.

HashJoinerStats are the stats collected during a hashJoiner run.

InputStats represents the stats collected from an input.

InvertedFiltererStats are the stats collected during an inverted filterer run.

InvertedJoinerStats are the stats collected during an invertedJoiner run.

JoinReaderStats are the stats collected during a JoinReader run.

MergeJoinerStats are the stats collected during a mergeJoiner run.

OrdinalityStats are the stats collected during a WITH ORDINALITY run.

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.

KeyIndex is used as a set element.

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