Class FilteringRecordMaterializer<T>
- java.lang.Object
-
- org.apache.parquet.io.api.RecordMaterializer<T>
-
- org.apache.parquet.filter2.recordlevel.FilteringRecordMaterializer<T>
-
public class FilteringRecordMaterializer<T> extends RecordMaterializer<T>
A pass-through proxy for aRecordMaterializer
that updates aIncrementallyUpdatedFilterPredicate
as it receives concrete values for the current record. If, after the record assembly signals that there are no more values, the predicate indicates that this record should be dropped,getCurrentRecord()
returns null to signal that this record is being skipped. Otherwise, the record is retrieved from the delegate.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.parquet.io.api.RecordMaterializer
RecordMaterializer.RecordMaterializationException
-
-
Constructor Summary
Constructors Constructor Description FilteringRecordMaterializer(RecordMaterializer<T> delegate, List<PrimitiveColumnIO> columnIOs, Map<org.apache.parquet.hadoop.metadata.ColumnPath,List<IncrementallyUpdatedFilterPredicate.ValueInspector>> valueInspectorsByColumn, IncrementallyUpdatedFilterPredicate filterPredicate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description T
getCurrentRecord()
static List<Integer>
getIndexFieldPathList(PrimitiveColumnIO c)
Deprecated.GroupConverter
getRootConverter()
static List<Integer>
intArrayToList(int[] arr)
Deprecated.void
skipCurrentRecord()
Called ifRecordMaterializer.getCurrentRecord()
isn't going to be called.
-
-
-
Constructor Detail
-
FilteringRecordMaterializer
public FilteringRecordMaterializer(RecordMaterializer<T> delegate, List<PrimitiveColumnIO> columnIOs, Map<org.apache.parquet.hadoop.metadata.ColumnPath,List<IncrementallyUpdatedFilterPredicate.ValueInspector>> valueInspectorsByColumn, IncrementallyUpdatedFilterPredicate filterPredicate)
-
-
Method Detail
-
getCurrentRecord
public T getCurrentRecord()
- Specified by:
getCurrentRecord
in classRecordMaterializer<T>
- Returns:
- the result of the conversion
-
skipCurrentRecord
public void skipCurrentRecord()
Description copied from class:RecordMaterializer
Called ifRecordMaterializer.getCurrentRecord()
isn't going to be called.- Overrides:
skipCurrentRecord
in classRecordMaterializer<T>
-
getRootConverter
public GroupConverter getRootConverter()
- Specified by:
getRootConverter
in classRecordMaterializer<T>
- Returns:
- the root converter for this tree
-
getIndexFieldPathList
@Deprecated public static List<Integer> getIndexFieldPathList(PrimitiveColumnIO c)
Deprecated.
-
intArrayToList
@Deprecated public static List<Integer> intArrayToList(int[] arr)
Deprecated.
-
-