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

Class StreamElementMaterializer.ParquetColumnRecordConverter

java.lang.Object

org.apache.parquet.io.api.Converter

org.apache.parquet.io.api.GroupConverter

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

Direct Known Subclasses:

StreamElementMaterializer.ParquetColumnListRecordConverter

Enclosing class:

StreamElementMaterializer

public static class StreamElementMaterializer.ParquetColumnRecordConverter
extends org.apache.parquet.io.api.GroupConverter

Field Summary

Fields

Modifier and Type	Field	Description
protected StreamElementMaterializer.ParquetColumnGroup	record

Constructor Summary

Constructors

Constructor	Description
ParquetColumnRecordConverter(org.apache.parquet.schema.GroupType schema, java.lang.String name, StreamElementMaterializer.ParquetColumnRecordConverter parent)

Method Summary

Modifier and Type	Method	Description
void	end()
org.apache.parquet.io.api.Converter	getConverter(int fieldIndex)
StreamElementMaterializer.ParquetColumnGroup	getCurrentRecord()
void	start()

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

asGroupConverter, isPrimitive

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

asPrimitiveConverter

Methods inherited from class java.lang.Object

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

Field Detail

record

protected StreamElementMaterializer.ParquetColumnGroup record

Constructor Detail

ParquetColumnRecordConverter

public ParquetColumnRecordConverter(org.apache.parquet.schema.GroupType schema,
                                    java.lang.String name,
                                    StreamElementMaterializer.ParquetColumnRecordConverter parent)

Method Detail

getConverter

public org.apache.parquet.io.api.Converter getConverter(int fieldIndex)

Specified by:

getConverter in class org.apache.parquet.io.api.GroupConverter

getCurrentRecord

public StreamElementMaterializer.ParquetColumnGroup getCurrentRecord()

start

public void start()

Specified by:

start in class org.apache.parquet.io.api.GroupConverter

end

public void end()

Specified by:

end in class org.apache.parquet.io.api.GroupConverter