CompareEncDatumRowForMerge 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.

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.

SubqueryExecModeDiscardAllRows indicates that the subquery is being executed for its side effects.

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.

JoinReaderNoOrderingStrategyBatchSize determines the size of input batches used to construct a single lookup KV batch by joinReaderNoOrderingStrategy.

JoinReaderOrderingStrategyBatchSize determines the size of input batches used to construct a single lookup KV batch by joinReaderOrderingStrategy.

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.

NewCloudStorageTestProcessor 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.

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

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

NewParquetWriterProcessor 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.

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

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

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

ParallelizeMultiKeyLookupJoinsEnabled determines whether the joinReader parallelizes KV batches in all cases.

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.

KeyIndex is used as a set element.

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