package expr
Import Path
github.com/polarsignals/frostdb/query/expr (on go.dev)
Dependency Relation
imports 8 packages, and imported by 3 packages
Package-Level Type Names (total 9)
(*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.
func BooleanExpr(expr logicalplan.Expr) (TrueNegativeFilter, error)
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)
![]() |
The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |