exprpb

Documentation

Index

• func AggregationFunctionToProto(e *logicalplan.AggregationFunction) (*storagepb.Expr, error)
• func AliasExprToProto(e *logicalplan.AliasExpr) (*storagepb.Expr, error)
• func BinaryExprToProto(e *logicalplan.BinaryExpr) (*storagepb.Expr, error)
• func ColumnExprToProto(e *logicalplan.Column) (*storagepb.Expr, error)
• func ConvertExprToProto(e *logicalplan.ConvertExpr) (*storagepb.Expr, error)
• func DurationExprToProto(e *logicalplan.DurationExpr) (*storagepb.Expr, error)
• func DynamicColumnExprToProto(e *logicalplan.DynamicColumn) (*storagepb.Expr, error)
• func ExprFromProto(expr *storagepb.Expr) (logicalplan.Expr, error)
• func ExprToProto(expr logicalplan.Expr) (*storagepb.Expr, error)
• func ExprsFromProtos(exprs []*storagepb.Expr) ([]logicalplan.Expr, error)
• func ExprsToProtos(exprs []logicalplan.Expr) ([]*storagepb.Expr, error)
• func IfExprToProto(e *logicalplan.IfExpr) (*storagepb.Expr, error)
• func LiteralExprToProto(e *logicalplan.LiteralExpr) (*storagepb.Expr, error)
• type Option
  • func WithPhysicalplanOptions(opts ...physicalplan.Option) Option
  • func WithTracer(tracer trace.Tracer) Option
• type ProtoEngine
  • func NewEngine(pool memory.Allocator, tableProvider logicalplan.TableProvider, ...) *ProtoEngine
  • func (e *ProtoEngine) FromProto(root *pb.PlanNode) (ProtoQueryBuilder, error)
• type ProtoQueryBuilder
  • func (qb ProtoQueryBuilder) Execute(ctx context.Context, callback func(ctx context.Context, r arrow.Record) error) error
  • func (qb ProtoQueryBuilder) Explain(ctx context.Context) (string, error)

Functions

func AggregationFunctionToProto

func AggregationFunctionToProto(e *logicalplan.AggregationFunction) (*storagepb.Expr, error)

func AliasExprToProto

func AliasExprToProto(e *logicalplan.AliasExpr) (*storagepb.Expr, error)

func BinaryExprToProto

func BinaryExprToProto(e *logicalplan.BinaryExpr) (*storagepb.Expr, error)

func ColumnExprToProto

func ColumnExprToProto(e *logicalplan.Column) (*storagepb.Expr, error)

func ConvertExprToProto

func ConvertExprToProto(e *logicalplan.ConvertExpr) (*storagepb.Expr, error)

func DurationExprToProto

func DurationExprToProto(e *logicalplan.DurationExpr) (*storagepb.Expr, error)

func DynamicColumnExprToProto

func DynamicColumnExprToProto(e *logicalplan.DynamicColumn) (*storagepb.Expr, error)

func ExprFromProto

func ExprFromProto(expr *storagepb.Expr) (logicalplan.Expr, error)

ExprFromProto converts a proto representation of an expression to the canonical logicalplan expressions representation.

func ExprToProto

func ExprToProto(expr logicalplan.Expr) (*storagepb.Expr, error)

func ExprsFromProtos

func ExprsFromProtos(exprs []*storagepb.Expr) ([]logicalplan.Expr, error)

ExprsFromProtos converts a slice of proto representations of expressions to the canonical logicalplan expressions representation.

func ExprsToProtos

func ExprsToProtos(exprs []logicalplan.Expr) ([]*storagepb.Expr, error)

func IfExprToProto

func IfExprToProto(e *logicalplan.IfExpr) (*storagepb.Expr, error)

func LiteralExprToProto

func LiteralExprToProto(e *logicalplan.LiteralExpr) (*storagepb.Expr, error)

Types

type Option

type Option func(*ProtoEngine)

func WithPhysicalplanOptions

func WithPhysicalplanOptions(opts ...physicalplan.Option) Option

func WithTracer

func WithTracer(tracer trace.Tracer) Option

type ProtoEngine

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

func NewEngine

func NewEngine(
	pool memory.Allocator,
	tableProvider logicalplan.TableProvider,
	options ...Option,
) *ProtoEngine

func (*ProtoEngine) FromProto

func (e *ProtoEngine) FromProto(root *pb.PlanNode) (ProtoQueryBuilder, error)

type ProtoQueryBuilder

type ProtoQueryBuilder struct {
	LogicalPlan *logicalplan.LogicalPlan
	// contains filtered or unexported fields
}

func (ProtoQueryBuilder) Execute

func (qb ProtoQueryBuilder) Execute(ctx context.Context, callback func(ctx context.Context, r arrow.Record) error) error

func (ProtoQueryBuilder) Explain

func (qb ProtoQueryBuilder) Explain(ctx context.Context) (string, error)