binaryfilterfunc

package
v1.1.2 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2023 License: Apache-2.0 Imports: 8 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
	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 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) (*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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.