Versions in this module Expand all Collapse all v1 v1.0.1 May 18, 2017 Changes in this version + var DistAggregationTable = map[distsqlrun.AggregatorSpec_Func]DistAggregationInfo + func MakeExpression(expr parser.TypedExpr, indexVarMap []int) distsqlrun.Expression + func MakeTypeIndexedVarHelper(types []sqlbase.ColumnType) parser.IndexedVarHelper + func MergePlans(left, right *PhysicalPlan) (mergedPlan PhysicalPlan, leftRouters []ProcessorIdx, ...) + type DistAggregationInfo struct + FinalRendering func(h *parser.IndexedVarHelper, varIdxOffset int) (parser.TypedExpr, error) + FinalStage []distsqlrun.AggregatorSpec_Func + LocalStage []distsqlrun.AggregatorSpec_Func + type LeaseHolderChoosingPolicy byte + const BinPackingLeaseHolderChoice + const RandomLeaseHolderChoice + type PhysicalPlan struct + MergeOrdering distsqlrun.Ordering + Processors []Processor + ResultRouters []ProcessorIdx + ResultTypes []sqlbase.ColumnType + Streams []Stream + func (p *PhysicalPlan) AddFilter(expr parser.TypedExpr, indexVarMap []int) + func (p *PhysicalPlan) AddLimit(count int64, offset int64, node roachpb.NodeID) error + func (p *PhysicalPlan) AddNoGroupingStage(core distsqlrun.ProcessorCoreUnion, post distsqlrun.PostProcessSpec, ...) + func (p *PhysicalPlan) AddProcessor(proc Processor) ProcessorIdx + func (p *PhysicalPlan) AddProjection(columns []uint32) + func (p *PhysicalPlan) AddRendering(exprs []parser.TypedExpr, indexVarMap []int, outTypes []sqlbase.ColumnType) + func (p *PhysicalPlan) AddSingleGroupStage(nodeID roachpb.NodeID, core distsqlrun.ProcessorCoreUnion, ...) + func (p *PhysicalPlan) GenerateFlowSpecs() map[roachpb.NodeID]distsqlrun.FlowSpec + func (p *PhysicalPlan) GetLastStagePost() distsqlrun.PostProcessSpec + func (p *PhysicalPlan) MergeResultStreams(resultRouters []ProcessorIdx, sourceRouterSlot int, ...) + func (p *PhysicalPlan) PopulateEndpoints(nodeAddresses map[roachpb.NodeID]string) + func (p *PhysicalPlan) SetLastStagePost(post distsqlrun.PostProcessSpec, outputTypes []sqlbase.ColumnType) + func (p *PhysicalPlan) SetMergeOrdering(o distsqlrun.Ordering) + type Processor struct + Node roachpb.NodeID + Spec distsqlrun.ProcessorSpec + type ProcessorIdx int + type SpanResolver interface + NewSpanResolverIterator func(txn *client.Txn) SpanResolverIterator + func NewFakeSpanResolver(nodes []*roachpb.NodeDescriptor) SpanResolver + func NewSpanResolver(distSender *kv.DistSender, gossip *gossip.Gossip, ...) SpanResolver + type SpanResolverIterator interface + Desc func() roachpb.RangeDescriptor + Error func() error + NeedAnother func() bool + Next func(ctx context.Context) + ReplicaInfo func(ctx context.Context) (kv.ReplicaInfo, error) + Seek func(ctx context.Context, span roachpb.Span, scanDir kv.ScanDirection) + Valid func() bool + type Stream struct + DestInput int + DestProcessor ProcessorIdx + SourceProcessor ProcessorIdx + SourceRouterSlot int
Go to main page