Class DrillParquetRecordMaterializer
java.lang.Object
org.apache.parquet.io.api.RecordMaterializer<Void>
org.apache.drill.exec.store.parquet2.DrillParquetRecordMaterializer
public class DrillParquetRecordMaterializer
extends org.apache.parquet.io.api.RecordMaterializer<Void>
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.parquet.io.api.RecordMaterializer
org.apache.parquet.io.api.RecordMaterializer.RecordMaterializationException
-
Constructor Summary
ConstructorDescriptionDrillParquetRecordMaterializer
(OutputMutator mutator, org.apache.parquet.schema.MessageType schema, Collection<SchemaPath> columns, OptionManager options, ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates) -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.parquet.io.api.GroupConverter
void
setPosition
(int position) void
setValueCount
(int count) Methods inherited from class org.apache.parquet.io.api.RecordMaterializer
skipCurrentRecord
-
Constructor Details
-
DrillParquetRecordMaterializer
public DrillParquetRecordMaterializer(OutputMutator mutator, org.apache.parquet.schema.MessageType schema, Collection<SchemaPath> columns, OptionManager options, ParquetReaderUtility.DateCorruptionStatus containsCorruptedDates)
-
-
Method Details
-
setPosition
public void setPosition(int position) -
setValueCount
public void setValueCount(int count) -
getCurrentRecord
- Specified by:
getCurrentRecord
in classorg.apache.parquet.io.api.RecordMaterializer<Void>
-
getRootConverter
public org.apache.parquet.io.api.GroupConverter getRootConverter()- Specified by:
getRootConverter
in classorg.apache.parquet.io.api.RecordMaterializer<Void>
-