binaryfilterfunc

Documentation

Index

• Constants
• func GetBooleanEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetBooleanNEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetFloatEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetFloatGTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetFloatGTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetFloatLTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetFloatLTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetFloatNEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetIntegerEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetIntegerGTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetIntegerGTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetIntegerLTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetIntegerLTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetIntegerNEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetStringEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetStringGTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetStringGTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetStringLTConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetStringLTEConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func GetStringNEQConditionBitMap(col *record.ColVal, compare interface{}, bitMap, pos []byte, offset int) []byte
• func HaveTimeCond(startTime, endTime int64) bool
• func LeftRotate(expr influxql.Expr) influxql.Expr
• func MoveOrOpToRoot(expr influxql.Expr) influxql.Expr
• func RewriteTimeCompareVal(expr influxql.Expr, valuer *influxql.NowValuer)
• func RightRotate(expr influxql.Expr) influxql.Expr
• func RotateOrOpToRoot(expr influxql.Expr) influxql.Expr
• func SplitWithOrOperation(expr influxql.Expr) []influxql.Expr
• type CondFunctions
  • func InitCondFunctions(expr influxql.Expr, schema *record.Schemas) (CondFunctions, error)
• type IdxFunction
• type IdxFunctions
  • func InitTimeCondFunctions(startTime, endTime int64, schema *record.Schemas) IdxFunctions

Constants

const (
	StringFunc int = iota
	FloatFunc
	IntFunc
	BoolFunc
	ColBottom
)

const (
	GT int = iota
	LT
	GTE
	LTE
	EQ
	NEQ
	BOTTOM
)

Functions

func GetBooleanEQConditionBitMap

func GetBooleanEQConditionBitMap(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 GetFloatEQConditionBitMap

func GetFloatEQConditionBitMap(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 GetFloatGTEConditionBitMap

func GetFloatGTEConditionBitMap(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 GetFloatLTEConditionBitMap

func GetFloatLTEConditionBitMap(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 GetIntegerEQConditionBitMap

func GetIntegerEQConditionBitMap(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 GetIntegerGTEConditionBitMap

func GetIntegerGTEConditionBitMap(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 GetIntegerLTEConditionBitMap

func GetIntegerLTEConditionBitMap(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 GetStringEQConditionBitMap

func GetStringEQConditionBitMap(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 GetStringGTEConditionBitMap

func GetStringGTEConditionBitMap(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 GetStringLTEConditionBitMap

func GetStringLTEConditionBitMap(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 HaveTimeCond

func HaveTimeCond(startTime, endTime int64) bool

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 IdxFunction

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

type IdxFunctions

type IdxFunctions []IdxFunction

func InitTimeCondFunctions

func InitTimeCondFunctions(startTime, endTime int64, schema *record.Schemas) IdxFunctions