plan

package

Go to main page

Versions in this module

v3

v3.9.0

Mar 7, 2025

v3.8.0

Feb 28, 2025

v3.7.0

Feb 13, 2025

Changes in this version

type AggregateRel

+ func (ar *AggregateRel) ToBuilder() *AggregateRelBuilder

type AggregateRelBuilder

+ func (arb *AggregateRelBuilder) ClearGrouping()

+ func (arb *AggregateRelBuilder) ClearMeasures()

+ func (arb *AggregateRelBuilder) ReplaceInput(rel *Rel)

v3.6.0

Feb 7, 2025

v3.5.1

Jan 29, 2025

v3.5.0

Jan 24, 2025

v3.4.0

Jan 16, 2025

Changes in this version

type Builder

+ IcebergTableFromMetadataFile func(metadataURI string, snapshot IcebergSnapshot, schema types.NamedStruct) (*IcebergTableReadRel, error)

+ type Direct struct

+ MetadataUri string

+ type IcebergSnapshot interface

+ type IcebergTableReadRel struct

+ func (b *IcebergTableReadRel) BaseSchema() types.NamedStruct

+ func (b *IcebergTableReadRel) BestEffortFilter() expr.Expression

+ func (b *IcebergTableReadRel) Filter() expr.Expression

+ func (b *IcebergTableReadRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (b *IcebergTableReadRel) GetInputs() []Rel

+ func (b *IcebergTableReadRel) Projection() *expr.MaskExpression

+ func (b *IcebergTableReadRel) SetProjection(p *expr.MaskExpression)

+ func (n *IcebergTableReadRel) Copy(_ ...Rel) (Rel, error)

+ func (n *IcebergTableReadRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, _ ...Rel) (Rel, error)

+ func (n *IcebergTableReadRel) NamedTableAdvancedExtension() *extensions.AdvancedExtension

+ func (n *IcebergTableReadRel) RecordType() types.RecordType

+ func (n *IcebergTableReadRel) Remap(mapping ...int32) (Rel, error)

+ func (n *IcebergTableReadRel) ToProto() *proto.Rel

+ func (n *IcebergTableReadRel) ToProtoPlanRel() *proto.PlanRel

+ type IcebergTableType interface

+ type SnapshotId string

+ type SnapshotTimestamp int64

v3.3.0

Jan 10, 2025

Changes in this version

type AggregateRel

+ func (ar *AggregateRel) GroupingExpressions() []expr.Expression

+ func (ar *AggregateRel) GroupingReferences() [][]uint32

+ func (ar *AggregateRel) SetGroupingExpressions(groupingExpressions []expr.Expression)

+ func (ar *AggregateRel) SetGroupingReferences(groupingReferences [][]uint32)

+ func (ar *AggregateRel) SetInput(input Rel)

+ func (ar *AggregateRel) SetMeasures(measures []AggRelMeasure)

+ type AggregateRelBuilder struct

+ func (arb *AggregateRelBuilder) AddCube(expressionReferences []uint32) error

+ func (arb *AggregateRelBuilder) AddExpression(e expr.Expression) uint32

+ func (arb *AggregateRelBuilder) AddGroupingSet(groupingReferences []uint32)

+ func (arb *AggregateRelBuilder) AddRollup(groupingReferences []uint32)

+ func (arb *AggregateRelBuilder) Build() (*AggregateRel, error)

type Builder

+ GetRelBuilder func() *RelBuilder

+ type RelBuilder struct

+ func (r *RelBuilder) AggregateRel(input Rel, measures []AggRelMeasure) *AggregateRelBuilder

v3.2.1

Jan 2, 2025

v3.2.0

Dec 20, 2024

v3.1.0

Dec 16, 2024

Changes in this version

+ const FETCH_COUNT_ALL_RECORDS

+ const JoinTypeInner

+ const JoinTypeLeft

+ const JoinTypeLeftAnti

+ const JoinTypeLeftSemi

+ const JoinTypeLeftSingle

+ const JoinTypeOuter

+ const JoinTypeRight

+ const JoinTypeRightAnti

+ const JoinTypeRightSemi

+ const JoinTypeRightSingle

+ const JoinTypeUnspecified

+ const OutputModeModifiedRecords

+ const OutputModeNoOutput

+ const OutputModeUnspecified

+ const SetOpIntersectionMultiset

+ const SetOpIntersectionPrimary

+ const SetOpMinusMultiset

+ const SetOpMinusPrimary

+ const SetOpUnionAll

+ const SetOpUnionDistinct

+ const SetOpUnspecified

+ const WriteOpCTAS

+ const WriteOpDelete

+ const WriteOpInsert

+ const WriteOpUnspecified

+ const WriteOpUpdate

+ var CurrentVersion = types.Version

+ type AdvancedExtension interface

+ GetEnhancement func() *anypb.Any

+ GetOptimization func() []*anypb.Any

+ type AggRelMeasure struct

+ func (am *AggRelMeasure) Filter() expr.Expression

+ func (am *AggRelMeasure) Measure() *expr.AggregateFunction

+ func (am *AggRelMeasure) ToProto() *proto.AggregateRel_Measure

+ type AggregateRel struct

+ func (ar *AggregateRel) Copy(newInputs ...Rel) (Rel, error)

+ func (ar *AggregateRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (ar *AggregateRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (ar *AggregateRel) GetInputs() []Rel

+ func (ar *AggregateRel) Groupings() [][]expr.Expression

+ func (ar *AggregateRel) Input() Rel

+ func (ar *AggregateRel) Measures() []AggRelMeasure

+ func (ar *AggregateRel) RecordType() types.RecordType

+ func (ar *AggregateRel) Remap(mapping ...int32) (Rel, error)

+ func (ar *AggregateRel) ToProto() *proto.Rel

+ func (ar *AggregateRel) ToProtoPlanRel() *proto.PlanRel

+ type ArrowReadOptions proto.ReadRel_LocalFiles_FileOrFiles_ArrowReadOptions

+ type BiRel interface

+ Left func() Rel

+ Right func() Rel

+ type Builder interface

+ AggregateColumns func(input Rel, measures []AggRelMeasure, groupByCols ...int32) (*AggregateRel, error)

+ AggregateColumnsRemap func(input Rel, remap []int32, measures []AggRelMeasure, groupByCols ...int32) (*AggregateRel, error)

+ AggregateExprs func(input Rel, measures []AggRelMeasure, groups ...[]expr.Expression) (*AggregateRel, error)

+ AggregateExprsRemap func(input Rel, remap []int32, measures []AggRelMeasure, ...) (*AggregateRel, error)

+ AggregateFn func(nameSpace, key string, opts []*types.FunctionOption, args ...types.FuncArg) (*expr.AggregateFunction, error)

+ CreateTableAsSelect func(input Rel, tableName []string, schema types.NamedStruct) (*NamedTableWriteRel, error)

+ CreateTableAsSelectRemap func(input Rel, remap []int32, tableName []string, schema types.NamedStruct) (*NamedTableWriteRel, error)

+ Cross func(left, right Rel) (*CrossRel, error)

+ CrossRemap func(left, right Rel, remap []int32) (*CrossRel, error)

+ Fetch func(input Rel, offset, count int64) (*FetchRel, error)

+ FetchRemap func(input Rel, offset, count int64, remap []int32) (*FetchRel, error)

+ Filter func(input Rel, condition expr.Expression) (*FilterRel, error)

+ FilterRemap func(input Rel, condition expr.Expression, remap []int32) (*FilterRel, error)

+ GetExprBuilder func() *expr.ExprBuilder

+ GetFunctionRef func(nameSpace, key string) types.FunctionRef

+ Join func(left, right Rel, condition expr.Expression, joinType JoinType) (*JoinRel, error)

+ JoinAndFilter func(left, right Rel, condition, postJoinFilter expr.Expression, joinType JoinType) (*JoinRel, error)

+ JoinAndFilterRemap func(left, right Rel, condition, postJoinFilter expr.Expression, joinType JoinType, ...) (*JoinRel, error)

+ JoinRemap func(left, right Rel, condition expr.Expression, joinType JoinType, remap []int32) (*JoinRel, error)

+ JoinedRecordFieldRef func(left, right Rel, index int32) (*expr.FieldReference, error)

+ Measure func(measure *expr.AggregateFunction, filter expr.Expression) AggRelMeasure

+ NamedDelete func(input Rel, tableName []string, schema types.NamedStruct) (*NamedTableWriteRel, error)

+ NamedInsert func(input Rel, tableName []string, schema types.NamedStruct) (*NamedTableWriteRel, error)

+ NamedScan func(tableName []string, schema types.NamedStruct) *NamedTableReadRel

+ NamedScanRemap func(tableName []string, schema types.NamedStruct, remap []int32) (*NamedTableReadRel, error)

+ NamedWrite func(input Rel, op WriteOp, tableName []string, schema types.NamedStruct) (*NamedTableWriteRel, error)

+ NamedWriteRemap func(input Rel, op WriteOp, tableName []string, schema types.NamedStruct, ...) (*NamedTableWriteRel, error)

+ Plan func(root Rel, rootNames []string, others ...Rel) (*Plan, error)

+ PlanWithTypes func(root Rel, rootNames []string, expectedTypeURLs []string, others ...Rel) (*Plan, error)

+ Project func(input Rel, exprs ...expr.Expression) (*ProjectRel, error)

+ ProjectRemap func(input Rel, remap []int32, exprs ...expr.Expression) (*ProjectRel, error)

+ RootFieldRef func(input Rel, index int32) (*expr.FieldReference, error)

+ ScalarFn func(nameSpace, key string, opts []*types.FunctionOption, args ...types.FuncArg) (*expr.ScalarFunction, error)

+ Set func(op SetOp, inputs ...Rel) (*SetRel, error)

+ SetRemap func(op SetOp, remap []int32, inputs ...Rel) (*SetRel, error)

+ Sort func(input Rel, sorts ...expr.SortField) (*SortRel, error)

+ SortFields func(input Rel, indices ...int32) ([]expr.SortField, error)

+ SortRemap func(input Rel, remap []int32, sorts ...expr.SortField) (*SortRel, error)

+ UserDefinedType func(nameSpace, typeName string, params ...types.TypeParam) types.UserDefinedType

+ VirtualTable func(fields []string, values ...expr.StructLiteralValue) (*VirtualTableReadRel, error)

+ VirtualTableFromExpr func(fieldNames []string, values ...expr.VirtualTableExpressionValue) (*VirtualTableReadRel, error)

+ VirtualTableFromExprRemap func(fieldNames []string, remap []int32, values ...expr.VirtualTableExpressionValue) (*VirtualTableReadRel, error)

+ VirtualTableRemap func(fields []string, remap []int32, values ...expr.StructLiteralValue) (*VirtualTableReadRel, error)

+ func NewBuilder(c *extensions.Collection) Builder

+ func NewBuilderDefault() Builder

+ type CrossRel struct

+ func (c *CrossRel) Copy(newInputs ...Rel) (Rel, error)

+ func (c *CrossRel) CopyWithExpressionRewrite(_ RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (c *CrossRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (c *CrossRel) GetInputs() []Rel

+ func (c *CrossRel) Left() Rel

+ func (c *CrossRel) RecordType() types.RecordType

+ func (c *CrossRel) Remap(mapping ...int32) (Rel, error)

+ func (c *CrossRel) Right() Rel

+ func (c *CrossRel) ToProto() *proto.Rel

+ func (c *CrossRel) ToProtoPlanRel() *proto.PlanRel

+ type DwrfReadOptions proto.ReadRel_LocalFiles_FileOrFiles_DwrfReadOptions

+ type ExtensionLeafRel struct

+ func (el *ExtensionLeafRel) Copy(_ ...Rel) (Rel, error)

+ func (el *ExtensionLeafRel) CopyWithExpressionRewrite(_ RewriteFunc, _ ...Rel) (Rel, error)

+ func (el *ExtensionLeafRel) Detail() *anypb.Any

+ func (el *ExtensionLeafRel) GetInputs() []Rel

+ func (el *ExtensionLeafRel) RecordType() types.RecordType

+ func (el *ExtensionLeafRel) Remap(mapping ...int32) (Rel, error)

+ func (el *ExtensionLeafRel) ToProto() *proto.Rel

+ func (el *ExtensionLeafRel) ToProtoPlanRel() *proto.PlanRel

+ type ExtensionMultiRel struct

+ func (em *ExtensionMultiRel) Copy(newInputs ...Rel) (Rel, error)

+ func (em *ExtensionMultiRel) CopyWithExpressionRewrite(_ RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (em *ExtensionMultiRel) Detail() *anypb.Any

+ func (em *ExtensionMultiRel) GetInputs() []Rel

+ func (em *ExtensionMultiRel) Inputs() []Rel

+ func (em *ExtensionMultiRel) RecordType() types.RecordType

+ func (em *ExtensionMultiRel) Remap(mapping ...int32) (Rel, error)

+ func (em *ExtensionMultiRel) ToProto() *proto.Rel

+ func (em *ExtensionMultiRel) ToProtoPlanRel() *proto.PlanRel

+ type ExtensionReadOptions anypb.Any

+ type ExtensionSingleRel struct

+ func (es *ExtensionSingleRel) Copy(newInputs ...Rel) (Rel, error)

+ func (es *ExtensionSingleRel) CopyWithExpressionRewrite(_ RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (es *ExtensionSingleRel) Detail() *anypb.Any

+ func (es *ExtensionSingleRel) GetInputs() []Rel

+ func (es *ExtensionSingleRel) Input() Rel

+ func (es *ExtensionSingleRel) RecordType() types.RecordType

+ func (es *ExtensionSingleRel) Remap(mapping ...int32) (Rel, error)

+ func (es *ExtensionSingleRel) ToProto() *proto.Rel

+ func (es *ExtensionSingleRel) ToProtoPlanRel() *proto.PlanRel

+ type ExtensionTableReadRel struct

+ func (b *ExtensionTableReadRel) BaseSchema() types.NamedStruct

+ func (b *ExtensionTableReadRel) BestEffortFilter() expr.Expression

+ func (b *ExtensionTableReadRel) Filter() expr.Expression

+ func (b *ExtensionTableReadRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (b *ExtensionTableReadRel) GetInputs() []Rel

+ func (b *ExtensionTableReadRel) Projection() *expr.MaskExpression

+ func (b *ExtensionTableReadRel) RecordType() types.RecordType

+ func (b *ExtensionTableReadRel) SetProjection(p *expr.MaskExpression)

+ func (e *ExtensionTableReadRel) Copy(_ ...Rel) (Rel, error)

+ func (e *ExtensionTableReadRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, _ ...Rel) (Rel, error)

+ func (e *ExtensionTableReadRel) Detail() *anypb.Any

+ func (e *ExtensionTableReadRel) Remap(mapping ...int32) (Rel, error)

+ func (e *ExtensionTableReadRel) ToProto() *proto.Rel

+ func (e *ExtensionTableReadRel) ToProtoPlanRel() *proto.PlanRel

+ type FetchRel struct

+ func (f *FetchRel) Copy(newInputs ...Rel) (Rel, error)

+ func (f *FetchRel) CopyWithExpressionRewrite(_ RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (f *FetchRel) Count() int64

+ func (f *FetchRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (f *FetchRel) GetInputs() []Rel

+ func (f *FetchRel) Input() Rel

+ func (f *FetchRel) Offset() int64

+ func (f *FetchRel) RecordType() types.RecordType

+ func (f *FetchRel) Remap(mapping ...int32) (Rel, error)

+ func (f *FetchRel) ToProto() *proto.Rel

+ func (f *FetchRel) ToProtoPlanRel() *proto.PlanRel

+ type FileFormat interface

+ type FileOrFiles struct

+ Format FileFormat

+ Len uint64

+ PartIndex uint64

+ Path string

+ PathType PathType

+ Start uint64

+ func (f *FileOrFiles) ToProto() *proto.ReadRel_LocalFiles_FileOrFiles

+ type FilterRel struct

+ func (fr *FilterRel) Condition() expr.Expression

+ func (fr *FilterRel) Copy(newInputs ...Rel) (Rel, error)

+ func (fr *FilterRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (fr *FilterRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (fr *FilterRel) GetInputs() []Rel

+ func (fr *FilterRel) Input() Rel

+ func (fr *FilterRel) RecordType() types.RecordType

+ func (fr *FilterRel) Remap(mapping ...int32) (Rel, error)

+ func (fr *FilterRel) ToProto() *proto.Rel

+ func (fr *FilterRel) ToProtoPlanRel() *proto.PlanRel

+ type HashJoinRel struct

+ func (hr *HashJoinRel) Copy(newInputs ...Rel) (Rel, error)

+ func (hr *HashJoinRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (hr *HashJoinRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (hr *HashJoinRel) GetInputs() []Rel

+ func (hr *HashJoinRel) Left() Rel

+ func (hr *HashJoinRel) LeftKeys() []*expr.FieldReference

+ func (hr *HashJoinRel) PostJoinFilter() expr.Expression

+ func (hr *HashJoinRel) RecordType() types.RecordType

+ func (hr *HashJoinRel) Remap(mapping ...int32) (Rel, error)

+ func (hr *HashJoinRel) Right() Rel

+ func (hr *HashJoinRel) RightKeys() []*expr.FieldReference

+ func (hr *HashJoinRel) ToProto() *proto.Rel

+ func (hr *HashJoinRel) ToProtoPlanRel() *proto.PlanRel

+ func (hr *HashJoinRel) Type() HashMergeJoinType

+ type HashMergeJoinType int8

+ const HashMergeInner

+ const HashMergeLeft

+ const HashMergeLeftAnti

+ const HashMergeLeftSemi

+ const HashMergeOuter

+ const HashMergeRight

+ const HashMergeRightAnti

+ const HashMergeRightSemi

+ const HashMergeUnspecified

+ type Hint = proto.RelCommon_Hint

+ type JoinRel struct

+ func (j *JoinRel) Copy(newInputs ...Rel) (Rel, error)

+ func (j *JoinRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (j *JoinRel) Expr() expr.Expression

+ func (j *JoinRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (j *JoinRel) GetInputs() []Rel

+ func (j *JoinRel) JoinedRecordType() types.RecordType

+ func (j *JoinRel) Left() Rel

+ func (j *JoinRel) PostJoinFilter() expr.Expression

+ func (j *JoinRel) RecordType() types.RecordType

+ func (j *JoinRel) Remap(mapping ...int32) (Rel, error)

+ func (j *JoinRel) Right() Rel

+ func (j *JoinRel) ToProto() *proto.Rel

+ func (j *JoinRel) ToProtoPlanRel() *proto.PlanRel

+ func (j *JoinRel) Type() JoinType

+ type JoinType = proto.JoinRel_JoinType

+ type LocalFileReadRel struct

+ func (b *LocalFileReadRel) BaseSchema() types.NamedStruct

+ func (b *LocalFileReadRel) BestEffortFilter() expr.Expression

+ func (b *LocalFileReadRel) Filter() expr.Expression

+ func (b *LocalFileReadRel) GetInputs() []Rel

+ func (b *LocalFileReadRel) Projection() *expr.MaskExpression

+ func (b *LocalFileReadRel) RecordType() types.RecordType

+ func (b *LocalFileReadRel) SetProjection(p *expr.MaskExpression)

+ func (lf *LocalFileReadRel) Copy(_ ...Rel) (Rel, error)

+ func (lf *LocalFileReadRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, _ ...Rel) (Rel, error)

+ func (lf *LocalFileReadRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (lf *LocalFileReadRel) Item(i int) FileOrFiles

+ func (lf *LocalFileReadRel) Remap(mapping ...int32) (Rel, error)

+ func (lf *LocalFileReadRel) ToProto() *proto.Rel

+ func (lf *LocalFileReadRel) ToProtoPlanRel() *proto.PlanRel

+ type MergeJoinRel struct

+ func (mr *MergeJoinRel) Copy(newInputs ...Rel) (Rel, error)

+ func (mr *MergeJoinRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (mr *MergeJoinRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (mr *MergeJoinRel) GetInputs() []Rel

+ func (mr *MergeJoinRel) Left() Rel

+ func (mr *MergeJoinRel) LeftKeys() []*expr.FieldReference

+ func (mr *MergeJoinRel) PostJoinFilter() expr.Expression

+ func (mr *MergeJoinRel) RecordType() types.RecordType

+ func (mr *MergeJoinRel) Remap(mapping ...int32) (Rel, error)

+ func (mr *MergeJoinRel) Right() Rel

+ func (mr *MergeJoinRel) RightKeys() []*expr.FieldReference

+ func (mr *MergeJoinRel) ToProto() *proto.Rel

+ func (mr *MergeJoinRel) ToProtoPlanRel() *proto.PlanRel

+ func (mr *MergeJoinRel) Type() HashMergeJoinType

+ type MultiRel interface

+ Inputs func() []Rel

+ type NamedTableReadRel struct

+ func (b *NamedTableReadRel) BaseSchema() types.NamedStruct

+ func (b *NamedTableReadRel) BestEffortFilter() expr.Expression

+ func (b *NamedTableReadRel) Filter() expr.Expression

+ func (b *NamedTableReadRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (b *NamedTableReadRel) GetInputs() []Rel

+ func (b *NamedTableReadRel) Projection() *expr.MaskExpression

+ func (b *NamedTableReadRel) SetProjection(p *expr.MaskExpression)

+ func (n *NamedTableReadRel) Copy(_ ...Rel) (Rel, error)

+ func (n *NamedTableReadRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, _ ...Rel) (Rel, error)

+ func (n *NamedTableReadRel) NamedTableAdvancedExtension() *extensions.AdvancedExtension

+ func (n *NamedTableReadRel) Names() []string

+ func (n *NamedTableReadRel) RecordType() types.RecordType

+ func (n *NamedTableReadRel) Remap(mapping ...int32) (Rel, error)

+ func (n *NamedTableReadRel) ToProto() *proto.Rel

+ func (n *NamedTableReadRel) ToProtoPlanRel() *proto.PlanRel

+ type NamedTableWriteRel struct

+ func (wr *NamedTableWriteRel) Copy(newInputs ...Rel) (Rel, error)

+ func (wr *NamedTableWriteRel) CopyWithExpressionRewrite(_ RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (wr *NamedTableWriteRel) GetInputs() []Rel

+ func (wr *NamedTableWriteRel) Input() Rel

+ func (wr *NamedTableWriteRel) NamedTableAdvancedExtension() *extensions.AdvancedExtension

+ func (wr *NamedTableWriteRel) Names() []string

+ func (wr *NamedTableWriteRel) Op() WriteOp

+ func (wr *NamedTableWriteRel) OutputMode() OutputMode

+ func (wr *NamedTableWriteRel) RecordType() types.RecordType

+ func (wr *NamedTableWriteRel) Remap(mapping ...int32) (Rel, error)

+ func (wr *NamedTableWriteRel) TableSchema() types.NamedStruct

+ func (wr *NamedTableWriteRel) ToProto() *proto.Rel

+ func (wr *NamedTableWriteRel) ToProtoPlanRel() *proto.PlanRel

+ type OrcReadOptions proto.ReadRel_LocalFiles_FileOrFiles_OrcReadOptions

+ type OutputMode = proto.WriteRel_OutputMode

+ type ParquetReadOptions proto.ReadRel_LocalFiles_FileOrFiles_ParquetReadOptions

+ type PathType int8

+ const URIFile

+ const URIFolder

+ const URIPath

+ const URIPathGlob

+ type Plan struct

+ func FromProto(plan *proto.Plan, c *extensions.Collection) (*Plan, error)

+ func (p *Plan) AdvancedExtension() AdvancedExtension

+ func (p *Plan) ExpectedTypeURLs() []string

+ func (p *Plan) ExtensionRegistry() expr.ExtensionRegistry

+ func (p *Plan) GetNonRootRelations() (rels []Rel)

+ func (p *Plan) GetRoots() (roots []*Root)

+ func (p *Plan) Relations() []Relation

+ func (p *Plan) ToProto() (*proto.Plan, error)

+ func (p *Plan) Version() Version

+ type ProjectRel struct

+ func (p *ProjectRel) Copy(newInputs ...Rel) (Rel, error)

+ func (p *ProjectRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (p *ProjectRel) Expressions() []expr.Expression

+ func (p *ProjectRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (p *ProjectRel) GetInputs() []Rel

+ func (p *ProjectRel) Input() Rel

+ func (p *ProjectRel) RecordType() types.RecordType

+ func (p *ProjectRel) Remap(mapping ...int32) (Rel, error)

+ func (p *ProjectRel) ToProto() *proto.Rel

+ func (p *ProjectRel) ToProtoPlanRel() *proto.PlanRel

+ type ReadRel interface

+ BaseSchema func() types.NamedStruct

+ BestEffortFilter func() expr.Expression

+ Filter func() expr.Expression

+ Projection func() *expr.MaskExpression

+ type Rel interface

+ Copy func(newInputs ...Rel) (Rel, error)

+ CopyWithExpressionRewrite func(rewriteFunc RewriteFunc, newInputs ...Rel) (Rel, error)

+ GetAdvancedExtension func() *extensions.AdvancedExtension

+ GetInputs func() []Rel

+ Hint func() *Hint

+ OutputMapping func() []int32

+ RecordType func() types.RecordType

+ Remap func(mapping ...int32) (Rel, error)

+ ToProto func() *proto.Rel

+ ToProtoPlanRel func() *proto.PlanRel

+ func RelFromProto(rel *proto.Rel, reg expr.ExtensionRegistry) (Rel, error)

+ func RemapHelper(r Rel, mapping []int32) (Rel, error)

+ type RelCommon struct

+ func (rc *RelCommon) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (rc *RelCommon) Hint() *Hint

+ func (rc *RelCommon) OutputMapping() []int32

+ type Relation struct

+ func (r *Relation) FromProto(p *proto.PlanRel, reg expr.ExtensionRegistry) error

+ func (r *Relation) IsRoot() bool

+ func (r *Relation) Rel() Rel

+ func (r *Relation) Root() *Root

+ func (r *Relation) ToProto() *proto.PlanRel

+ type RewriteFunc func(expr.Expression) (expr.Expression, error)

+ type Root struct

+ func (r *Root) Input() Rel

+ func (r *Root) Names() []string

+ func (r *Root) RecordType() types.NamedStruct

+ func (r *Root) ToProtoPlanRel() *proto.PlanRel

+ type RuntimeConstraint = proto.RelCommon_Hint_RuntimeConstraint

+ type SetOp = proto.SetRel_SetOp

+ type SetRel struct

+ func (s *SetRel) Copy(newInputs ...Rel) (Rel, error)

+ func (s *SetRel) CopyWithExpressionRewrite(_ RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (s *SetRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (s *SetRel) GetInputs() []Rel

+ func (s *SetRel) Inputs() []Rel

+ func (s *SetRel) Op() SetOp

+ func (s *SetRel) RecordType() types.RecordType

+ func (s *SetRel) Remap(mapping ...int32) (Rel, error)

+ func (s *SetRel) ToProto() *proto.Rel

+ func (s *SetRel) ToProtoPlanRel() *proto.PlanRel

+ type SingleInputRel interface

+ Input func() Rel

+ type SortRel struct

+ func (sr *SortRel) Copy(newInputs ...Rel) (Rel, error)

+ func (sr *SortRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, newInputs ...Rel) (Rel, error)

+ func (sr *SortRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (sr *SortRel) GetInputs() []Rel

+ func (sr *SortRel) Input() Rel

+ func (sr *SortRel) RecordType() types.RecordType

+ func (sr *SortRel) Remap(mapping ...int32) (Rel, error)

+ func (sr *SortRel) Sorts() []expr.SortField

+ func (sr *SortRel) ToProto() *proto.Rel

+ func (sr *SortRel) ToProtoPlanRel() *proto.PlanRel

+ type Stats = proto.RelCommon_Hint_Stats

+ type Version interface

+ GetGitHash func() string

+ GetMajorNumber func() uint32

+ GetMinorNumber func() uint32

+ GetPatchNumber func() uint32

+ GetProducer func() string

+ type VirtualTableReadRel struct

+ func (b *VirtualTableReadRel) BaseSchema() types.NamedStruct

+ func (b *VirtualTableReadRel) BestEffortFilter() expr.Expression

+ func (b *VirtualTableReadRel) Filter() expr.Expression

+ func (b *VirtualTableReadRel) GetAdvancedExtension() *extensions.AdvancedExtension

+ func (b *VirtualTableReadRel) GetInputs() []Rel

+ func (b *VirtualTableReadRel) Projection() *expr.MaskExpression

+ func (b *VirtualTableReadRel) RecordType() types.RecordType

+ func (b *VirtualTableReadRel) SetProjection(p *expr.MaskExpression)

+ func (v *VirtualTableReadRel) Copy(_ ...Rel) (Rel, error)

+ func (v *VirtualTableReadRel) CopyWithExpressionRewrite(rewriteFunc RewriteFunc, _ ...Rel) (Rel, error)

+ func (v *VirtualTableReadRel) Remap(mapping ...int32) (Rel, error)

+ func (v *VirtualTableReadRel) ToProto() *proto.Rel

+ func (v *VirtualTableReadRel) ToProtoPlanRel() *proto.PlanRel

+ func (v *VirtualTableReadRel) Values() []expr.VirtualTableExpressionValue

+ type WriteOp = proto.WriteRel_WriteOp

Other modules containing this package

github.com/substrait-io/substrait-go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL