binaryfilterfunc

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 29, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StringFunc int = iota
	FloatFunc
	IntFunc
	BoolFunc
	ColBottom
)
View Source
const (
	GT int = iota
	LT
	GTE
	LTE
	EQ
	NEQ
	MATHCHPHRASE
	BOTTOM
)

Variables

This section is empty.

Functions

func CombineConditionWithAnd added in v1.1.1

func CombineConditionWithAnd(lhs, rhs influxql.Expr) influxql.Expr

func GetBooleanEQConditionBitMap

func GetBooleanEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetBooleanEQConditionBitMapWithNull

func GetBooleanEQConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetBooleanEQConditionBitMapWithoutNull

func GetBooleanEQConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetBooleanNEQConditionBitMap

func GetBooleanNEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetBooleanNEQConditionBitMapWithNull

func GetBooleanNEQConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetBooleanNEQConditionBitMapWithoutNull

func GetBooleanNEQConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatEQConditionBitMap

func GetFloatEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatEQConditionBitMapWithNull

func GetFloatEQConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatEQConditionBitMapWithoutNull

func GetFloatEQConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatGTConditionBitMap

func GetFloatGTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatGTConditionBitMapWithNull

func GetFloatGTConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatGTConditionBitMapWithoutNull

func GetFloatGTConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatGTEConditionBitMap

func GetFloatGTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatGTEConditionBitMapWithNull

func GetFloatGTEConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatGTEConditionBitMapWithoutNull

func GetFloatGTEConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatLTConditionBitMap

func GetFloatLTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatLTConditionBitMapWithNull

func GetFloatLTConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatLTConditionBitMapWithoutNull

func GetFloatLTConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatLTEConditionBitMap

func GetFloatLTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatLTEConditionBitMapWithNull

func GetFloatLTEConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatLTEConditionBitMapWithoutNull

func GetFloatLTEConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatNEQConditionBitMap

func GetFloatNEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatNEQConditionBitMapWithNull

func GetFloatNEQConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetFloatNEQConditionBitMapWithoutNull

func GetFloatNEQConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerEQConditionBitMap

func GetIntegerEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerEQConditionBitMapWithNull

func GetIntegerEQConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerEQConditionBitMapWithoutNull

func GetIntegerEQConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerGTConditionBitMap

func GetIntegerGTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerGTConditionBitMapWithNull

func GetIntegerGTConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerGTConditionBitMapWithoutNull

func GetIntegerGTConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerGTEConditionBitMap

func GetIntegerGTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerGTEConditionBitMapWithNull

func GetIntegerGTEConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerGTEConditionBitMapWithoutNull

func GetIntegerGTEConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerLTConditionBitMap

func GetIntegerLTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerLTConditionBitMapWithNull

func GetIntegerLTConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerLTConditionBitMapWithoutNull

func GetIntegerLTConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerLTEConditionBitMap

func GetIntegerLTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerLTEConditionBitMapWithNull

func GetIntegerLTEConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerLTEConditionBitMapWithoutNull

func GetIntegerLTEConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerNEQConditionBitMap

func GetIntegerNEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerNEQConditionBitMapWithNull

func GetIntegerNEQConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetIntegerNEQConditionBitMapWithoutNull

func GetIntegerNEQConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringEQConditionBitMap

func GetStringEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringEQConditionBitMapWithNull

func GetStringEQConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringEQConditionBitMapWithoutNull

func GetStringEQConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringGTConditionBitMap

func GetStringGTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringGTConditionBitMapWithNull

func GetStringGTConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringGTConditionBitMapWithoutNull

func GetStringGTConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringGTEConditionBitMap

func GetStringGTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringGTEConditionBitMapWithNull

func GetStringGTEConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringGTEConditionBitMapWithoutNull

func GetStringGTEConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringLTConditionBitMap

func GetStringLTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringLTConditionBitMapWithNull

func GetStringLTConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringLTConditionBitMapWithoutNull

func GetStringLTConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringLTEConditionBitMap

func GetStringLTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringLTEConditionBitMapWithNull

func GetStringLTEConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringLTEConditionBitMapWithoutNull

func GetStringLTEConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringMatchPhraseConditionBitMap added in v1.2.0

func GetStringMatchPhraseConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringMatchPhraseConditionBitMapWithNull added in v1.2.0

func GetStringMatchPhraseConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringMatchPhraseConditionBitMapWithoutNull added in v1.2.0

func GetStringMatchPhraseConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringNEQConditionBitMap

func GetStringNEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringNEQConditionBitMapWithNull

func GetStringNEQConditionBitMapWithNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetStringNEQConditionBitMapWithoutNull

func GetStringNEQConditionBitMapWithoutNull(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte

func GetTimeCondition added in v1.1.1

func GetTimeCondition(tr util.TimeRange, schema record.Schemas, tcIdx int) influxql.Expr

func LeftRotate

func LeftRotate(expr influxql.Expr) influxql.Expr

func MoveOrOpToRoot

func MoveOrOpToRoot(expr influxql.Expr) influxql.Expr

func RewriteTimeCompareVal

func RewriteTimeCompareVal(expr influxql.Expr, valuer *influxql.NowValuer)

func RightRotate

func RightRotate(expr influxql.Expr) influxql.Expr

func RotateOrOpToRoot

func RotateOrOpToRoot(expr influxql.Expr) influxql.Expr

func SplitWithOrOperation

func SplitWithOrOperation(expr influxql.Expr) []influxql.Expr

Types

type CondFunctions

type CondFunctions []IdxFunctions

func InitCondFunctions

func InitCondFunctions(expr influxql.Expr, schema *record.Schemas) (CondFunctions, error)

type ConditionImpl added in v1.1.1

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

func NewCondition added in v1.1.1

func NewCondition(timeCondition, condition influxql.Expr, schema record.Schemas, opt hybridqp.Options) (*ConditionImpl, error)

func (*ConditionImpl) Filter added in v1.1.1

func (c *ConditionImpl) Filter(rec *record.Record, filterBitmap *bitmap.FilterBitmap) error

func (*ConditionImpl) HaveFilter added in v1.1.1

func (c *ConditionImpl) HaveFilter() bool

func (*ConditionImpl) NumFilter added in v1.1.1

func (c *ConditionImpl) NumFilter() int

type IdxFunction

type IdxFunction struct {
	Idx      int
	Function func(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
	Compare  interface{}
	Op       influxql.Token
}

type IdxFunctions

type IdxFunctions []IdxFunction

type RPNElement added in v1.1.1

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

Jump to

Keyboard shortcuts

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