package expr

Import Path
	github.com/polarsignals/frostdb/query/expr (on go.dev)

Dependency Relation
	imports 8 packages, and imported by 3 packages

Involved Source Files binaryscalarexpr.go filter.go
Package-Level Type Names (total 9)
/* sort by: | */
(*AlwaysTrueFilter) Eval(_ Particulate, _ bool) (bool, error) *AlwaysTrueFilter : TrueNegativeFilter
Left TrueNegativeFilter Right TrueNegativeFilter (*AndExpr) Eval(p Particulate, ignoreMissingCols bool) (bool, error) *AndExpr : TrueNegativeFilter
Left *ColumnRef Op logicalplan.Op Right parquet.Value ( BinaryScalarExpr) Eval(p Particulate, ignoreMissingCol bool) (bool, error) BinaryScalarExpr : TrueNegativeFilter
ColumnName string (*ColumnRef) Column(p Particulate) (parquet.ColumnChunk, bool, error)
(*MaxAgg) Eval(p Particulate, _ bool) (bool, error) *MaxAgg : TrueNegativeFilter
Left TrueNegativeFilter Right TrueNegativeFilter (*OrExpr) Eval(p Particulate, ignoreMissingCols bool) (bool, error) *OrExpr : TrueNegativeFilter
Particulate is an abstraction of something that can be filtered. A parquet.RowGroup is a particulate that is able to be filtered, and wrapping a parquet.File with ParquetFileParticulate allows a file to be filtered. ( Particulate) ColumnChunks() []parquet.ColumnChunk ( Particulate) Schema() *parquet.Schema *github.com/polarsignals/frostdb/dynparquet.Buffer github.com/polarsignals/frostdb/dynparquet.DynamicRowGroup (interface) *github.com/polarsignals/frostdb/dynparquet.DynamicRowGroupMergeAdapter github.com/polarsignals/frostdb/dynparquet.MergedRowGroup github.com/polarsignals/frostdb/dynparquet.PooledBuffer github.com/polarsignals/frostdb/index.ReleaseableRowGroup (interface) *github.com/parquet-go/parquet-go.Buffer *github.com/parquet-go/parquet-go.GenericBuffer[...] *github.com/parquet-go/parquet-go.RowBuffer[...] github.com/parquet-go/parquet-go.RowGroup (interface) func (*AlwaysTrueFilter).Eval(_ Particulate, _ bool) (bool, error) func (*AndExpr).Eval(p Particulate, ignoreMissingCols bool) (bool, error) func BinaryScalarExpr.Eval(p Particulate, ignoreMissingCol bool) (bool, error) func (*ColumnRef).Column(p Particulate) (parquet.ColumnChunk, bool, error) func (*MaxAgg).Eval(p Particulate, _ bool) (bool, error) func (*OrExpr).Eval(p Particulate, ignoreMissingCols bool) (bool, error) func TrueNegativeFilter.Eval(p Particulate, ignoreMissingCols bool) (bool, error)
( PreExprVisitorFunc) PostVisit(_ logicalplan.Expr) bool ( PreExprVisitorFunc) PreVisit(expr logicalplan.Expr) bool ( PreExprVisitorFunc) Visit(_ logicalplan.Expr) bool PreExprVisitorFunc : github.com/polarsignals/frostdb/query/logicalplan.Visitor
Eval should be safe to call concurrently. *AlwaysTrueFilter *AndExpr BinaryScalarExpr *MaxAgg *OrExpr func BooleanExpr(expr logicalplan.Expr) (TrueNegativeFilter, error) func github.com/polarsignals/frostdb.(*DefaultObjstoreBucket).ProcessFile(ctx context.Context, blockDir string, lastBlockTimestamp uint64, filter TrueNegativeFilter, callback func(context.Context, any) error) error
Package-Level Functions (total 5)
BinaryScalarOperation applies the given operator between the given column chunk and value. If BinaryScalarOperation returns true, it means that the operator may be satisfied by at least one value in the column chunk. If it returns false, it means that the operator will definitely not be satisfied by any value in the column chunk.
Max returns the maximum value found in the column chunk across all pages.
Min returns the minimum value found in the column chunk across all pages.
func NullCount(columnIndex parquet.ColumnIndex) int64
Package-Level Variables (only one)