substrait

Documentation

Index

• func ConvertExpr(schema *iceberg.Schema, e iceberg.BooleanExpression, caseSensitive bool) (*expr.ExtensionRegistry, expr.Expression, error)
• func ConvertSchema(schema *iceberg.Schema) (res types.NamedStruct, err error)
• func NewExtensionSet() exprs.ExtensionIDSet

Functions

func ConvertExpr

func ConvertExpr(schema *iceberg.Schema, e iceberg.BooleanExpression, caseSensitive bool) (*expr.ExtensionRegistry, expr.Expression, error)

ConvertExpr binds the provided expression to the given schema and converts it to a substrait expression so that it can be utilized for computation.

func ConvertSchema

func ConvertSchema(schema *iceberg.Schema) (res types.NamedStruct, err error)

ConvertSchema converts an Iceberg schema to a substrait NamedStruct using the appropriate types and column names.

func NewExtensionSet

func NewExtensionSet() exprs.ExtensionIDSet