org.apache.parquet.hadoop

Class ColumnChunkIncReadStore

java.lang.Object

org.apache.parquet.hadoop.ColumnChunkIncReadStore

All Implemented Interfaces:

org.apache.parquet.column.page.PageReadStore

public class ColumnChunkIncReadStore
extends Object
implements org.apache.parquet.column.page.PageReadStore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ColumnChunkIncReadStore.ColumnChunkIncPageReader

Constructor Summary

Constructors

Constructor and Description
ColumnChunkIncReadStore(long rowCount, org.apache.parquet.hadoop.CodecFactory codecFactory, BufferAllocator allocator, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)

Method Summary

Modifier and Type	Method and Description
void	addColumn(org.apache.parquet.column.ColumnDescriptor descriptor, org.apache.parquet.hadoop.metadata.ColumnChunkMetaData metaData)
void	close()
org.apache.parquet.column.page.PageReader	getPageReader(org.apache.parquet.column.ColumnDescriptor descriptor)
long	getRowCount()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.parquet.column.page.PageReadStore

getRowIndexes

Constructor Detail

ColumnChunkIncReadStore

public ColumnChunkIncReadStore(long rowCount,
                               org.apache.parquet.hadoop.CodecFactory codecFactory,
                               BufferAllocator allocator,
                               org.apache.hadoop.fs.FileSystem fs,
                               org.apache.hadoop.fs.Path path)

Method Detail

addColumn

public void addColumn(org.apache.parquet.column.ColumnDescriptor descriptor,
                      org.apache.parquet.hadoop.metadata.ColumnChunkMetaData metaData)
               throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

getPageReader

public org.apache.parquet.column.page.PageReader getPageReader(org.apache.parquet.column.ColumnDescriptor descriptor)

Specified by:

getPageReader in interface org.apache.parquet.column.page.PageReadStore

getRowCount

public long getRowCount()

Specified by:

getRowCount in interface org.apache.parquet.column.page.PageReadStore

toString

public String toString()

Overrides:

toString in class Object