Package cz.o2.proxima.direct.io.bulkfs.parquet

Class StreamElementMaterializer

java.lang.Object

org.apache.parquet.io.api.RecordMaterializer<StreamElement>

cz.o2.proxima.direct.io.bulkfs.parquet.StreamElementMaterializer

@Internal
public class StreamElementMaterializer
extends org.apache.parquet.io.api.RecordMaterializer<StreamElement>

Class responsible for converting parquet record into StreamElement.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamElementMaterializer.ParquetColumnGroup
static class	StreamElementMaterializer.ParquetColumnListGroup
static class	StreamElementMaterializer.ParquetColumnListRecordConverter
static class	StreamElementMaterializer.ParquetColumnRecordConverter

Nested classes/interfaces inherited from class org.apache.parquet.io.api.RecordMaterializer

org.apache.parquet.io.api.RecordMaterializer.RecordMaterializationException

Constructor Summary

Constructors

Constructor	Description
StreamElementMaterializer(org.apache.parquet.schema.MessageType schema, EntityDescriptor entity, java.lang.String attributeNamesPrefix)

Method Summary

Modifier and Type	Method	Description
StreamElement	getCurrentRecord()
org.apache.parquet.io.api.GroupConverter	getRootConverter()

Methods inherited from class org.apache.parquet.io.api.RecordMaterializer

skipCurrentRecord

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamElementMaterializer

public StreamElementMaterializer(org.apache.parquet.schema.MessageType schema,
                                 EntityDescriptor entity,
                                 java.lang.String attributeNamesPrefix)

Method Detail

getCurrentRecord

public StreamElement getCurrentRecord()

Specified by:

getCurrentRecord in class org.apache.parquet.io.api.RecordMaterializer<StreamElement>

getRootConverter

public org.apache.parquet.io.api.GroupConverter getRootConverter()

Specified by:

getRootConverter in class org.apache.parquet.io.api.RecordMaterializer<StreamElement>