extensions

package

Go to main page

Versions in this module

v1

v1.2.0

Nov 1, 2024

v1.1.0

Oct 1, 2024

Changes in this version

type AggregateFunctionVariant

+ func (s *AggregateFunctionVariant) MaxArgumentCount() int

+ func (s *AggregateFunctionVariant) MinArgumentCount() int

type FunctionVariant

+ MaxArgumentCount func() int

+ MinArgumentCount func() int

type ScalarFunctionVariant

+ func (s *ScalarFunctionVariant) MaxArgumentCount() int

+ func (s *ScalarFunctionVariant) MinArgumentCount() int

type WindowFunctionVariant

+ func (s *WindowFunctionVariant) MaxArgumentCount() int

+ func (s *WindowFunctionVariant) MinArgumentCount() int

v1.0.1

Sep 19, 2024

v1.0.0

Sep 14, 2024

Changes in this version

+ func HasSyncParams(params []types.FuncDefArgType) bool

type AggregateFunctionVariant

+ func (s *AggregateFunctionVariant) Match(argumentTypes []types.Type) (bool, error)

+ func (s *AggregateFunctionVariant) MatchAt(typ types.Type, pos int) (bool, error)

type FunctionVariant

+ Match func(argumentTypes []types.Type) (bool, error)

+ MatchAt func(typ types.Type, pos int) (bool, error)

type ScalarFunctionVariant

+ func (s *ScalarFunctionVariant) Match(argumentTypes []types.Type) (bool, error)

+ func (s *ScalarFunctionVariant) MatchAt(typ types.Type, pos int) (bool, error)

type WindowFunctionVariant

+ func (s *WindowFunctionVariant) Match(argumentTypes []types.Type) (bool, error)

+ func (s *WindowFunctionVariant) MatchAt(typ types.Type, pos int) (bool, error)

v0

v0.8.0

Aug 26, 2024

v0.7.0

Aug 21, 2024

Changes in this version

type Collection

+ func (c *Collection) GetAllAggregateFunctions() []*AggregateFunctionVariant

+ func (c *Collection) GetAllScalarFunctions() []*ScalarFunctionVariant

+ func (c *Collection) GetAllWindowFunctions() []*WindowFunctionVariant

type VariadicBehavior

+ func (v *VariadicBehavior) IsValidArgumentCount(count int) bool

v0.6.0

Aug 10, 2024

v0.5.0

Jul 20, 2024

v0.4.2

Aug 17, 2023

Changes in this version

type AggregateFunctionVariant

+ func (s *AggregateFunctionVariant) ID() ID

type ScalarFunctionVariant

+ func (s *ScalarFunctionVariant) ID() ID

type WindowFunctionVariant

+ func (s *WindowFunctionVariant) ID() ID

v0.4.1

Aug 3, 2023

v0.4.0

Jun 21, 2023

v0.3.0

May 17, 2023

v0.2.0

May 10, 2023

v0.1.0

Mar 23, 2023

Changes in this version

+ const SubstraitDefaultURIPrefix

+ func EvaluateTypeExpression(nullHandling NullabilityHandling, expr parser.TypeExpression, ...) (types.Type, error)

+ type AdvancedExtension = extensions.AdvancedExtension

+ type AggVariantOptions struct

+ Decomposable DecomposeType

+ Deterministic bool

+ IntermediateOutputType string

+ MaxSet uint

+ Ordered bool

+ SessionDependant bool

+ Variadic *VariadicBehavior

+ type AggregateFunction struct

+ Description string

+ Impls []AggregateFunctionImpl

+ Name string

+ func (s *AggregateFunction) GetVariants(uri string) []*AggregateFunctionVariant

+ func (s *AggregateFunction) ResolveURI(uri string) []FunctionVariant

+ type AggregateFunctionImpl struct

+ Decomposable DecomposeType

+ Intermediate parser.TypeExpression

+ MaxSet int

+ Ordered bool

+ type AggregateFunctionVariant struct

+ func NewAggFuncVariant(id ID) *AggregateFunctionVariant

+ func NewAggFuncVariantOpts(id ID, opts AggVariantOptions) *AggregateFunctionVariant

+ func (s *AggregateFunctionVariant) Args() ArgumentList

+ func (s *AggregateFunctionVariant) CompoundName() string

+ func (s *AggregateFunctionVariant) Decomposability() DecomposeType

+ func (s *AggregateFunctionVariant) Description() string

+ func (s *AggregateFunctionVariant) Deterministic() bool

+ func (s *AggregateFunctionVariant) Intermediate() (types.Type, error)

+ func (s *AggregateFunctionVariant) MaxSet() int

+ func (s *AggregateFunctionVariant) Name() string

+ func (s *AggregateFunctionVariant) Nullability() NullabilityHandling

+ func (s *AggregateFunctionVariant) Options() map[string]Option

+ func (s *AggregateFunctionVariant) Ordered() bool

+ func (s *AggregateFunctionVariant) ResolveType(argumentTypes []types.Type) (types.Type, error)

+ func (s *AggregateFunctionVariant) SessionDependent() bool

+ func (s *AggregateFunctionVariant) URI() string

+ func (s *AggregateFunctionVariant) Variadic() *VariadicBehavior

+ type Argument interface

+ type ArgumentList []Argument

+ func (a *ArgumentList) UnmarshalYAML(fn func(interface{}) error) error

+ type Collection struct

+ var DefaultCollection Collection

+ func (c *Collection) GetAggregateFunc(id ID) (*AggregateFunctionVariant, bool)

+ func (c *Collection) GetScalarFunc(id ID) (*ScalarFunctionVariant, bool)

+ func (c *Collection) GetType(id ID) (t Type, ok bool)

+ func (c *Collection) GetTypeVariation(id ID) (tv TypeVariation, ok bool)

+ func (c *Collection) GetWindowFunc(id ID) (*WindowFunctionVariant, bool)

+ func (c *Collection) Load(uri string, r io.Reader) error

+ func (c *Collection) URILoaded(uri string) bool

+ type DecomposeType string

+ const DecomposeMany

+ const DecomposeNone

+ const DecomposeOne

+ type EnumArg struct

+ Description string

+ Name string

+ Options []string

+ type Function interface

+ ResolveURI func(uri string) []FunctionVariant

+ type FunctionVariant interface

+ Args func() ArgumentList

+ CompoundName func() string

+ Description func() string

+ Name func() string

+ Options func() map[string]Option

+ ResolveType func(argTypes []types.Type) (types.Type, error)

+ URI func() string

+ Variadic func() *VariadicBehavior

+ type ID struct

+ Name string

+ URI string

+ type NullabilityHandling string

+ const DeclaredOutputNullability

+ const DiscreteNullability

+ const MirrorNullability

+ type Option struct

+ Description string

+ Values []string

+ type ParamType string

+ const ParamBool

+ const ParamDataType

+ const ParamEnum

+ const ParamInteger

+ const ParamString

+ type ParameterConsistency string

+ const ConsistentParams

+ const InconsistentParams

+ type ScalarFunction struct

+ Description string

+ Impls []ScalarFunctionImpl

+ Name string

+ func (s *ScalarFunction) GetVariants(uri string) []*ScalarFunctionVariant

+ func (s *ScalarFunction) ResolveURI(uri string) []FunctionVariant

+ type ScalarFunctionImpl struct

+ Args ArgumentList

+ Deterministic bool

+ Implementation map[string]string

+ Nullability NullabilityHandling

+ Options map[string]Option

+ Return parser.TypeExpression

+ SessionDependent bool

+ Variadic *VariadicBehavior

+ type ScalarFunctionVariant struct

+ func NewScalarFuncVariant(id ID) *ScalarFunctionVariant

+ func NewScalarFuncVariantWithProps(id ID, variadic *VariadicBehavior, sessionDependant, deterministic bool) *ScalarFunctionVariant

+ func (s *ScalarFunctionVariant) Args() ArgumentList

+ func (s *ScalarFunctionVariant) CompoundName() string

+ func (s *ScalarFunctionVariant) Description() string

+ func (s *ScalarFunctionVariant) Deterministic() bool

+ func (s *ScalarFunctionVariant) Name() string

+ func (s *ScalarFunctionVariant) Nullability() NullabilityHandling

+ func (s *ScalarFunctionVariant) Options() map[string]Option

+ func (s *ScalarFunctionVariant) ResolveType(argumentTypes []types.Type) (types.Type, error)

+ func (s *ScalarFunctionVariant) SessionDependent() bool

+ func (s *ScalarFunctionVariant) URI() string

+ func (s *ScalarFunctionVariant) Variadic() *VariadicBehavior

+ type Set interface

+ DecodeFunc func(anchor uint32) (ID, bool)

+ DecodeType func(anchor uint32) (ID, bool)

+ DecodeTypeVariation func(anchor uint32) (ID, bool)

+ FindURI func(uri string) (uint32, bool)

+ GetFuncAnchor func(id ID) uint32

+ GetTypeAnchor func(id ID) uint32

+ GetTypeVariationAnchor func(id ID) uint32

+ LookupAggregateFunction func(anchor uint32, c *Collection) (*AggregateFunctionVariant, bool)

+ LookupScalarFunction func(anchor uint32, c *Collection) (*ScalarFunctionVariant, bool)

+ LookupType func(anchor uint32, c *Collection) (Type, bool)

+ LookupTypeVariation func(anchor uint32, c *Collection) (TypeVariation, bool)

+ LookupWindowFunction func(anchor uint32, c *Collection) (*WindowFunctionVariant, bool)

+ ToProto func() ([]*extensions.SimpleExtensionURI, []*extensions.SimpleExtensionDeclaration)

+ func GetExtensionSet(plan TopLevel) Set

+ func NewSet() Set

+ type SimpleExtensionFile struct

+ AggregateFunctions []AggregateFunction

+ ScalarFunctions []ScalarFunction

+ TypeVariations []TypeVariation

+ Types []Type

+ WindowFunctions []WindowFunction

+ type TopLevel interface

+ GetExtensionUris func() []*extensions.SimpleExtensionURI

+ GetExtensions func() []*extensions.SimpleExtensionDeclaration

+ type Type struct

+ Name string

+ Parameters []TypeParamDef

+ Structure TypeDef

+ Variadic bool

+ type TypeArg struct

+ Description string

+ Name string

+ Type string

+ type TypeDef any

+ type TypeParamDef struct

+ Description string

+ Max int

+ Min int

+ Name string

+ Optional bool

+ Options []string

+ Type ParamType

+ type TypeVariation struct

+ Description string

+ Functions TypeVariationFunctions

+ Name string

+ Parent parser.TypeExpression

+ type TypeVariationFunctions string

+ const TypeVariationInheritsFuncs

+ const TypeVariationSeparateFuncs

+ type ValueArg struct

+ Constant bool

+ Description string

+ Name string

+ Value *parser.TypeExpression

+ type VariadicBehavior struct

+ Max int

+ Min int

+ ParameterConsistency ParameterConsistency

+ type WindowFunction struct

+ Description string

+ Impls []WindowFunctionImpl

+ Name string

+ func (s *WindowFunction) GetVariants(uri string) []*WindowFunctionVariant

+ func (s *WindowFunction) ResolveURI(uri string) []FunctionVariant

+ type WindowFunctionImpl struct

+ WindowType WindowType

+ type WindowFunctionVariant struct

+ func NewWindowFuncVariant(id ID) *WindowFunctionVariant

+ func NewWindowFuncVariantOpts(id ID, opts WindowVariantOpts) *WindowFunctionVariant

+ func (s *WindowFunctionVariant) Args() ArgumentList

+ func (s *WindowFunctionVariant) CompoundName() string

+ func (s *WindowFunctionVariant) Decomposability() DecomposeType

+ func (s *WindowFunctionVariant) Description() string

+ func (s *WindowFunctionVariant) Deterministic() bool

+ func (s *WindowFunctionVariant) Intermediate() (types.Type, error)

+ func (s *WindowFunctionVariant) MaxSet() int

+ func (s *WindowFunctionVariant) Name() string

+ func (s *WindowFunctionVariant) Nullability() NullabilityHandling

+ func (s *WindowFunctionVariant) Options() map[string]Option

+ func (s *WindowFunctionVariant) Ordered() bool

+ func (s *WindowFunctionVariant) ResolveType(argumentTypes []types.Type) (types.Type, error)

+ func (s *WindowFunctionVariant) SessionDependent() bool

+ func (s *WindowFunctionVariant) URI() string

+ func (s *WindowFunctionVariant) Variadic() *VariadicBehavior

+ func (s *WindowFunctionVariant) WindowType() WindowType

+ type WindowType string

+ const PartitionWindow

+ const StreamingWindow

+ type WindowVariantOpts struct

+ Decomposable DecomposeType

+ Deterministic bool

+ IntermediateOutputType string

+ MaxSet uint

+ Ordered bool

+ SessionDependant bool

+ Variadic *VariadicBehavior

+ WindowType WindowType

Other modules containing this package

github.com/substrait-io/substrait-go/v3

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