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 JoinFn
  • func NewJoinFn(fn interpreter.ResolvedFunction) *JoinFn
  • func (f *JoinFn) Eval(ctx context.Context, p *joinProduct, method string, mem memory.Allocator) ([]table.Chunk, bool, error)
  • func (f *JoinFn) Prepare(lcols, rcols []flux.ColMeta) error
  • func (f *JoinFn) ReturnType() semantic.MonoType
  • func (f *JoinFn) Type() semantic.MonoType
• type JoinOpSpec
  • func (o *JoinOpSpec) Kind() flux.OperationKind
• type JoinProcedureSpec
  • func (p *JoinProcedureSpec) Copy() plan.ProcedureSpec
  • func (p *JoinProcedureSpec) Kind() plan.ProcedureKind
• type MergeJoinTransformation
  • func NewMergeJoinTransformation(ctx context.Context, id execute.DatasetID, s plan.ProcedureSpec, ...) (*MergeJoinTransformation, error)
  • func (t *MergeJoinTransformation) Dataset() *execute.TransportDataset
  • func (t *MergeJoinTransformation) ProcessMessage(m execute.Message) error
• 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
  • func (p *SortMergeJoinProcedureSpec) RequiredAttributes() []plan.PhysicalAttributes

Constants

const EquiJoinKind = "equijoin"

const Join2Kind = "join.tables"

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 JoinFn

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

JoinFn handles the logic of calling the function in the `as` parameter of join.tables()

func NewJoinFn

func NewJoinFn(fn interpreter.ResolvedFunction) *JoinFn

func (*JoinFn) Eval

func (f *JoinFn) Eval(ctx context.Context, p *joinProduct, method string, mem memory.Allocator) ([]table.Chunk, bool, error)

Produces the output of the joinProduct, if there is any to be produced. In some cases, the specified join method might require that no output be produced if one side is empty. If the returned bool == true, that means this function returned a non-empty table chunk containing the joined data.

func (*JoinFn) Prepare

func (f *JoinFn) Prepare(lcols, rcols []flux.ColMeta) error

func (*JoinFn) ReturnType

func (f *JoinFn) ReturnType() semantic.MonoType

func (*JoinFn) Type

func (f *JoinFn) Type() semantic.MonoType

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 MergeJoinTransformation

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

MergeJoinTransformation performs a sort-merge-join on two table streams. It assumes that input tables are sorted by the columns in the `on` parameter, and that we're performing an equijoin. The planner should ensure that both of these assumptions are true.

func NewMergeJoinTransformation

func NewMergeJoinTransformation(
	ctx context.Context,
	id execute.DatasetID,
	s plan.ProcedureSpec,
	leftID execute.DatasetID,
	rightID execute.DatasetID,
	mem memory.Allocator,
) (*MergeJoinTransformation, error)

func (*MergeJoinTransformation) Dataset

func (t *MergeJoinTransformation) Dataset() *execute.TransportDataset

func (*MergeJoinTransformation) ProcessMessage

func (t *MergeJoinTransformation) ProcessMessage(m execute.Message) error

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

func (*SortMergeJoinProcedureSpec) RequiredAttributes

func (p *SortMergeJoinProcedureSpec) RequiredAttributes() []plan.PhysicalAttributes

RequiredAttributes says that merge join must have its left input sorted by the left side join keys, and the right input must be sorted by the right side join keys.