Struct PhysicalFilterContext 

pub(crate) struct PhysicalFilterContext {
    filter: Arc<dyn PhysicalExpr>,
    expr_str: String,
    column_id: ColumnId,
    column_name: String,
    semantic_type: SemanticType,
    schema: SchemaRef,
    immutable: bool,
}

Context to evaluate a physical expression for a parquet file.

Fields

filter: Arc<dyn PhysicalExpr>

Filter to evaluate.

expr_str: String

Debug string of the original logical expression.

column_id: ColumnId

Id of the column to evaluate.

column_name: String

Name of the column to evaluate.

semantic_type: SemanticType

Semantic type of the column.

schema: SchemaRef

Schema containing only the referenced column.

immutable: bool

Whether the original logical expression is immutable across queries.

Implementations

impl PhysicalFilterContext

pub(crate) fn new_opt( sst_meta: &RegionMetadataRef, expected_meta: Option<&RegionMetadata>, read_format: &FlatReadFormat, expr: &Expr, ) -> Option<Self>

Creates a context for the expr.

Returns None if the expression doesn’t reference exactly one column or the column to filter doesn’t exist in the SST metadata or the expected metadata.

fn is_prefilter_candidate(expr: &Expr) -> bool

Returns true if the expression is a variant we want to evaluate as a physical prefilter. Binary exprs are intentionally excluded because [SimpleFilterEvaluator] already handles them.

fn single_column_name(expr: &Expr) -> Option<String>

pub(crate) fn filter(&self) -> &Arc<dyn PhysicalExpr>

Returns the filter to evaluate.

pub(crate) fn expr_str(&self) -> &str

Returns the original logical expression string.

pub(crate) fn column_id(&self) -> ColumnId

Returns the column id.

pub(crate) fn column_name(&self) -> &str

Returns the column name.

pub(crate) fn semantic_type(&self) -> SemanticType

Returns the semantic type of the column.

pub(crate) fn schema(&self) -> &SchemaRef

Returns the schema containing only the referenced column.

pub(crate) fn is_immutable(&self) -> bool

Returns true if the original logical expression is immutable across queries.

Trait Implementations

impl Clone for PhysicalFilterContext

fn clone(&self) -> PhysicalFilterContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.