spec

Documentation

Index

• Constants
• func CreateLogicalMockNode(id string) *plan.LogicalNode
• func CreatePhysicalMockNode(id string) *plan.PhysicalPlanNode
• func CreatePlanSpec(spec *PlanSpec) *plan.Spec
• type MockProcedureSpec
  • func (MockProcedureSpec) Copy() plan.ProcedureSpec
  • func (MockProcedureSpec) Kind() plan.ProcedureKind
  • func (s MockProcedureSpec) OutputAttributes() plan.PhysicalAttributes
  • func (s MockProcedureSpec) PassThroughAttribute(attrKey string) bool
  • func (s MockProcedureSpec) PlanDetails() string
  • func (s MockProcedureSpec) RequiredAttributes() []plan.PhysicalAttributes
• type PlanSpec
  • func (ps *PlanSpec) Copy() *PlanSpec

Constants

const MockKind = "mock"

Functions

func CreateLogicalMockNode

func CreateLogicalMockNode(id string) *plan.LogicalNode

CreateLogicalMockNode creates a mock plan node that doesn't match any rules (other than rules that match any node)

func CreatePhysicalMockNode

func CreatePhysicalMockNode(id string) *plan.PhysicalPlanNode

CreatePhysicalMockNode creates a mock plan node that doesn't match any rules (other than rules that match any node)

func CreatePlanSpec

func CreatePlanSpec(spec *PlanSpec) *plan.Spec

CreatePlanSpec creates a logical plan from a set of nodes and edges

Types

type MockProcedureSpec

type MockProcedureSpec struct {
	plan.DefaultCost
	OutputAttributesFn     func() plan.PhysicalAttributes
	PassThroughAttributeFn func(attrKey string) bool
	RequiredAttributesFn   func() []plan.PhysicalAttributes
	PlanDetailsFn          func() string
}

MockProcedureSpec provides a type that implements ProcedureSpec but does not require importing packages which register rules and procedure kinds, which makes it useful for unit testing.

func (MockProcedureSpec) Copy

func (MockProcedureSpec) Copy() plan.ProcedureSpec

func (MockProcedureSpec) Kind

func (MockProcedureSpec) Kind() plan.ProcedureKind

func (MockProcedureSpec) OutputAttributes

func (s MockProcedureSpec) OutputAttributes() plan.PhysicalAttributes

func (MockProcedureSpec) PassThroughAttribute

func (s MockProcedureSpec) PassThroughAttribute(attrKey string) bool

func (MockProcedureSpec) PlanDetails

func (s MockProcedureSpec) PlanDetails() string

func (MockProcedureSpec) RequiredAttributes

func (s MockProcedureSpec) RequiredAttributes() []plan.PhysicalAttributes

type PlanSpec

type PlanSpec struct {
	Nodes []plan.Node

	// Edges is a list of predecessor-to-successor edges.
	// [1, 3] => Nodes[1] is a predecessor of Nodes[3].
	// Predecessor ordering must be encoded in this list.
	Edges [][2]int

	Resources flux.ResourceManagement

	Now time.Time
}

Spec is a set of nodes and edges of a logical query plan

func (*PlanSpec) Copy

func (ps *PlanSpec) Copy() *PlanSpec

Copy makes a copy of a Spec.