Package replicaoracle provides functionality for physicalplan to choose a replica for a range.

MakeExpression creates a execinfrapb.Expression.

MergePlans merges the processors and streams of two plan into a new plan.

MergeResultTypes reconciles the ResultTypes between two plans.

NewFakeSpanResolver creates a fake span resolver.

NewFlowSpec returns a new FlowSpec, which may have non-zero capacity in its slice fields.

NewSpanResolver creates a new spanResolver.

NewTableReaderSpec returns a new TableReaderSpec.

ReleaseFlowSpec returns this FlowSpec back to the pool of FlowSpecs.

ReleaseSetupFlowRequest releases the resources of this SetupFlowRequest, putting them back into their respective object pools.

ReleaseTableReaderSpec puts this TableReaderSpec back into its sync pool.

DistAggregationTable is DistAggregationInfo look-up table.

DistAggregationInfo is a blueprint for planning distributed aggregations.

FinalStageInfo is a wrapper around an aggregation function performed in the final stage of distributed aggregations that allows us to specify the corresponding inputs from the local aggregations by their indices in the LocalStage.

PhysicalPlan represents a network of processors and streams along with information about the results output by this network.

Processor contains the information associated with a processor in a plan.

Stream connects the output router of one processor to an input synchronizer of another processor.

ExprContext is an interface containing objects necessary for creating execinfrapb.Expressions.

SpanResolver resolves key spans to their respective ranges and lease holders.

SpanResolverIterator is used to iterate over the ranges composing a key span.

ProcessorIdx identifies a processor by its index in PhysicalPlan.Processors.