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
- type ProtoEngine
- type ProtoQueryBuilder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
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
}
Source Files
Click to show internal directories.
Click to hide internal directories.