exprutil

Documentation

Index

• func GetCommonDataType(a *PlanRange, b *PlanRange) schemapb.DataType
• func IntRangeOverlap(range1 *IntRange, range2 *IntRange) bool
• func ParseExprFromPlan(plan *planpb.PlanNode) (*planpb.Expr, error)
• func ParseKeys(expr *planpb.Expr, kType KeyType) []*planpb.GenericValue
• func ParseKeysFromExpr(expr *planpb.Expr, keyType KeyType) ([]*planpb.GenericValue, bool)
• func ParsePartitionKeysFromBinaryExpr(expr *planpb.BinaryExpr, keyType KeyType) ([]*planpb.GenericValue, bool)
• func ParsePartitionKeysFromTermExpr(expr *planpb.TermExpr, keyType KeyType) ([]*planpb.GenericValue, bool)
• func ParsePartitionKeysFromUnaryExpr(expr *planpb.UnaryExpr, keyType KeyType) ([]*planpb.GenericValue, bool)
• func ParsePartitionKeysFromUnaryRangeExpr(expr *planpb.UnaryRangeExpr, keyType KeyType) ([]*planpb.GenericValue, bool)
• func StrRangeOverlap(range1 *StrRange, range2 *StrRange) bool
• func ValidatePartitionKeyIsolation(expr *planpb.Expr) error
• type IntRange
  • func NewIntRange(l int64, r int64, includeL bool, includeR bool) *IntRange
• type KeyType
• type PlanRange
  • func Intersect(a *PlanRange, b *PlanRange) *PlanRange
  • func ParseRanges(expr *planpb.Expr, kType KeyType) ([]*PlanRange, bool)
  • func ParseRangesFromBinaryExpr(expr *planpb.BinaryExpr, kType KeyType) ([]*PlanRange, bool)
  • func ParseRangesFromTermExpr(expr *planpb.TermExpr, kType KeyType) ([]*PlanRange, bool)
  • func ParseRangesFromUnaryRangeExpr(expr *planpb.UnaryRangeExpr, kType KeyType) ([]*PlanRange, bool)
  • func (planRange *PlanRange) ToIntRange() *IntRange
  • func (planRange *PlanRange) ToStrRange() *StrRange
• type StrRange
  • func NewStrRange(l string, r string, includeL bool, includeR bool) *StrRange

Functions

func GetCommonDataType

func GetCommonDataType(a *PlanRange, b *PlanRange) schemapb.DataType

func IntRangeOverlap

func IntRangeOverlap(range1 *IntRange, range2 *IntRange) bool

func ParseExprFromPlan

func ParseExprFromPlan(plan *planpb.PlanNode) (*planpb.Expr, error)

func ParseKeys

func ParseKeys(expr *planpb.Expr, kType KeyType) []*planpb.GenericValue

func ParseKeysFromExpr

func ParseKeysFromExpr(expr *planpb.Expr, keyType KeyType) ([]*planpb.GenericValue, bool)

func ParsePartitionKeysFromBinaryExpr

func ParsePartitionKeysFromBinaryExpr(expr *planpb.BinaryExpr, keyType KeyType) ([]*planpb.GenericValue, bool)

func ParsePartitionKeysFromTermExpr

func ParsePartitionKeysFromTermExpr(expr *planpb.TermExpr, keyType KeyType) ([]*planpb.GenericValue, bool)

func ParsePartitionKeysFromUnaryExpr

func ParsePartitionKeysFromUnaryExpr(expr *planpb.UnaryExpr, keyType KeyType) ([]*planpb.GenericValue, bool)

func ParsePartitionKeysFromUnaryRangeExpr

func ParsePartitionKeysFromUnaryRangeExpr(expr *planpb.UnaryRangeExpr, keyType KeyType) ([]*planpb.GenericValue, bool)

func StrRangeOverlap

func StrRangeOverlap(range1 *StrRange, range2 *StrRange) bool

func ValidatePartitionKeyIsolation

func ValidatePartitionKeyIsolation(expr *planpb.Expr) error

Types

type IntRange

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

func NewIntRange

func NewIntRange(l int64, r int64, includeL bool, includeR bool) *IntRange

type KeyType

type KeyType int64

const (
	PartitionKey  KeyType = iota
	ClusteringKey KeyType = PartitionKey + 1
)

type PlanRange

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

func Intersect

func Intersect(a *PlanRange, b *PlanRange) *PlanRange

func ParseRanges

func ParseRanges(expr *planpb.Expr, kType KeyType) ([]*PlanRange, bool)

func ParseRangesFromBinaryExpr

func ParseRangesFromBinaryExpr(expr *planpb.BinaryExpr, kType KeyType) ([]*PlanRange, bool)

func ParseRangesFromTermExpr

func ParseRangesFromTermExpr(expr *planpb.TermExpr, kType KeyType) ([]*PlanRange, bool)

func ParseRangesFromUnaryRangeExpr

func ParseRangesFromUnaryRangeExpr(expr *planpb.UnaryRangeExpr, kType KeyType) ([]*PlanRange, bool)

func (*PlanRange) ToIntRange

func (planRange *PlanRange) ToIntRange() *IntRange

func (*PlanRange) ToStrRange

func (planRange *PlanRange) ToStrRange() *StrRange

type StrRange

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

func NewStrRange

func NewStrRange(l string, r string, includeL bool, includeR bool) *StrRange