join

Documentation

Index

• Constants
• type ColumnPair
• type EquiJoinPredicateRule
  • func (EquiJoinPredicateRule) Name() string
  • func (EquiJoinPredicateRule) Pattern() plan.Pattern
  • func (EquiJoinPredicateRule) Rewrite(ctx context.Context, n plan.Node) (plan.Node, bool, error)
• type EquiJoinProcedureSpec
  • func (p *EquiJoinProcedureSpec) Copy() plan.ProcedureSpec
  • func (p *EquiJoinProcedureSpec) Cost(inStats []plan.Statistics) (cost plan.Cost, outStats plan.Statistics)
  • func (p *EquiJoinProcedureSpec) Kind() plan.ProcedureKind
• type JoinOpSpec
  • func (o *JoinOpSpec) Kind() flux.OperationKind
• type JoinProcedureSpec
  • func (p *JoinProcedureSpec) Copy() plan.ProcedureSpec
  • func (p *JoinProcedureSpec) Kind() plan.ProcedureKind
• type SortMergeJoinPredicateRule
  • func (SortMergeJoinPredicateRule) Name() string
  • func (SortMergeJoinPredicateRule) Pattern() plan.Pattern
  • func (SortMergeJoinPredicateRule) Rewrite(ctx context.Context, n plan.Node) (plan.Node, bool, error)
• type SortMergeJoinProcedureSpec
  • func (p *SortMergeJoinProcedureSpec) Copy() plan.ProcedureSpec
  • func (p *SortMergeJoinProcedureSpec) Cost(inStats []plan.Statistics) (cost plan.Cost, outStats plan.Statistics)
  • func (p *SortMergeJoinProcedureSpec) Kind() plan.ProcedureKind

Constants

const EquiJoinKind = "equijoin"

const Join2Kind = "join.join"

const SortMergeJoinKind = "sortmergejoin"

Types

type ColumnPair

type ColumnPair struct {
	Left, Right string
}

type EquiJoinPredicateRule

type EquiJoinPredicateRule struct{}

func (EquiJoinPredicateRule) Name

func (EquiJoinPredicateRule) Name() string

func (EquiJoinPredicateRule) Pattern

func (EquiJoinPredicateRule) Pattern() plan.Pattern

func (EquiJoinPredicateRule) Rewrite

func (EquiJoinPredicateRule) Rewrite(ctx context.Context, n plan.Node) (plan.Node, bool, error)

type EquiJoinProcedureSpec

type EquiJoinProcedureSpec struct {
	On     []ColumnPair
	As     interpreter.ResolvedFunction
	Left   *flux.TableObject
	Right  *flux.TableObject
	Method string
}

func (*EquiJoinProcedureSpec) Copy

func (p *EquiJoinProcedureSpec) Copy() plan.ProcedureSpec

func (*EquiJoinProcedureSpec) Cost

func (p *EquiJoinProcedureSpec) Cost(inStats []plan.Statistics) (cost plan.Cost, outStats plan.Statistics)

func (*EquiJoinProcedureSpec) Kind

func (p *EquiJoinProcedureSpec) Kind() plan.ProcedureKind

type JoinOpSpec

type JoinOpSpec struct {
	// contains filtered or unexported fields
}

func (*JoinOpSpec) Kind

func (o *JoinOpSpec) Kind() flux.OperationKind

type JoinProcedureSpec

type JoinProcedureSpec struct {
	On     interpreter.ResolvedFunction
	As     interpreter.ResolvedFunction
	Left   *flux.TableObject
	Right  *flux.TableObject
	Method string
}

func (*JoinProcedureSpec) Copy

func (p *JoinProcedureSpec) Copy() plan.ProcedureSpec

func (*JoinProcedureSpec) Kind

func (p *JoinProcedureSpec) Kind() plan.ProcedureKind

type SortMergeJoinPredicateRule

type SortMergeJoinPredicateRule struct{}

func (SortMergeJoinPredicateRule) Name

func (SortMergeJoinPredicateRule) Name() string

func (SortMergeJoinPredicateRule) Pattern

func (SortMergeJoinPredicateRule) Pattern() plan.Pattern

func (SortMergeJoinPredicateRule) Rewrite

func (SortMergeJoinPredicateRule) Rewrite(ctx context.Context, n plan.Node) (plan.Node, bool, error)

type SortMergeJoinProcedureSpec

type SortMergeJoinProcedureSpec EquiJoinProcedureSpec

func (*SortMergeJoinProcedureSpec) Copy

func (p *SortMergeJoinProcedureSpec) Copy() plan.ProcedureSpec

func (*SortMergeJoinProcedureSpec) Cost

func (p *SortMergeJoinProcedureSpec) Cost(inStats []plan.Statistics) (cost plan.Cost, outStats plan.Statistics)

func (*SortMergeJoinProcedureSpec) Kind

func (p *SortMergeJoinProcedureSpec) Kind() plan.ProcedureKind