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

MakeExpression creates a execinfrapb.Expression.

MakePhysicalPlan initializes a PhysicalPlan.

MergePlans is used when merging two plans into a new plan.

NewFakeSpanResolver creates a fake span resolver.

NewPhysicalInfrastructure initializes a PhysicalInfrastructure that can then be used with MakePhysicalPlan.

NewSpanResolver creates a new spanResolver.

NewTableReaderSpec returns a new TableReaderSpec.

ReleaseFlowSpec returns this FlowSpec back to the pool of FlowSpecs.

FullyDistributedPlan indicates that the whole plan is distributed.

LocalPlan indicates that the whole plan is executed on the gateway node.

PartiallyDistributedPlan indicates that some parts of the plan are distributed while other parts are not (due to limitations of DistSQL).

DefaultReplicaChooser is a nil replicaoracle.Oracle which can be passed in place of a replica oracle to some APIs to indicate they can use their default replica oracle.

DistAggregationTable is DistAggregationInfo look-up table.

DistAggregationInfo is a blueprint for planning distributed aggregations.

ExprFactory creates execinfrapb.Expressions.

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.

PhysicalInfrastructure stores information about processors and streams.

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.

ProcessorCorePlacement indicates on which node a particular processor core needs to be planned.

SerialStreamErrorSpec specifies when to error out serial unordered stream execution, and the error to use.

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.

PlanDistribution describes the distribution of the physical plan.

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