Class FilterEvaluatorUtils
java.lang.Object
org.apache.drill.exec.store.parquet.FilterEvaluatorUtils
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
Search through a LogicalExpression, finding all internal schema path references and returning them in a set. -
Method Summary
Modifier and TypeMethodDescriptionstatic RowsMatch
evalFilter
(LogicalExpression expr, MetadataBase.ParquetTableMetadataBase footer, int rowGroupIndex, OptionManager options, FragmentContext fragmentContext) static RowsMatch
matches
(LogicalExpression expr, Map<SchemaPath, ColumnStatistics<?>> columnsStatistics, TupleMetadata schema, long rowCount, UdfUtilities udfUtilities, FunctionLookupContext functionImplementationRegistry, Set<SchemaPath> schemaPathsInExpr) static <T extends Comparable<T>>
RowsMatchmatches
(FilterPredicate<T> parquetPredicate, Map<SchemaPath, ColumnStatistics<?>> columnsStatistics, long rowCount, TupleMetadata fileMetadata, Set<SchemaPath> schemaPathsInExpr, UdfUtilities udfUtilities)
-
Method Details
-
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, UdfUtilities udfUtilities)
-