Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

distsqlplan

package

Go to main page

Versions in this module

v1

v1.1.9

Oct 1, 2018

Changes in this version

type PhysicalPlan

+ func (p *PhysicalPlan) NewStageID() int32

v1.1.0-rc.1

Oct 4, 2017

v1.0.2

Jun 7, 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

Incompatible versions in this module

v19.2.0-alpha.20190805+incompatible

Aug 1, 2019

v19.1.3+incompatible

Jul 4, 2019

v19.1.0-beta.20190304+incompatible

Feb 27, 2019

v2.0.0+incompatible

Apr 3, 2018