org.apache.drill.exec.store.parquet

Class FilterEvaluatorUtils

java.lang.Object

org.apache.drill.exec.store.parquet.FilterEvaluatorUtils

public class FilterEvaluatorUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FilterEvaluatorUtils.FieldReferenceFinder Search through a LogicalExpression, finding all internal schema path references and returning them in a set.

Method Summary

Modifier and Type	Method and Description
static RowsMatch	evalFilter(LogicalExpression expr, MetadataBase.ParquetTableMetadataBase footer, int rowGroupIndex, OptionManager options, FragmentContext fragmentContext)
static <T extends Comparable<T>> RowsMatch	matches(FilterPredicate<T> parquetPredicate, Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, long rowCount, TupleMetadata fileMetadata, Set<SchemaPath> schemaPathsInExpr)
static RowsMatch	matches(LogicalExpression expr, Map<SchemaPath,ColumnStatistics<?>> columnsStatistics, TupleMetadata schema, long rowCount, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, Set<SchemaPath> schemaPathsInExpr)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

evalFilter

public static RowsMatch evalFilter(LogicalExpression expr,
                                   MetadataBase.ParquetTableMetadataBase footer,
                                   int rowGroupIndex,
                                   OptionManager options,
                                   FragmentContext fragmentContext)

matches

public static RowsMatch matches(LogicalExpression expr,
                                Map<SchemaPath,ColumnStatistics<?>> columnsStatistics,
                                TupleMetadata schema,
                                long rowCount,
                                UdfUtilities udfUtilities,
                                FunctionLookupContext functionImplementationRegistry,
                                Set<SchemaPath> schemaPathsInExpr)

matches

public static <T extends Comparable<T>> RowsMatch matches(FilterPredicate<T> parquetPredicate,
                                                          Map<SchemaPath,ColumnStatistics<?>> columnsStatistics,
                                                          long rowCount,
                                                          TupleMetadata fileMetadata,
                                                          Set<SchemaPath> schemaPathsInExpr)