Package org.apache.drill.exec.store.parquet

Class RowGroupInfo

java.lang.Object

org.apache.drill.exec.store.dfs.ReadEntryWithPath

org.apache.drill.exec.store.dfs.ReadEntryFromHDFS

org.apache.drill.exec.store.parquet.RowGroupInfo

All Implemented Interfaces:

Comparable<CompleteWork>, FileWork, CompleteWork

public class RowGroupInfo
extends ReadEntryFromHDFS
implements CompleteWork, FileWork

Field Summary

Fields inherited from class org.apache.drill.exec.store.dfs.ReadEntryWithPath

path

Fields inherited from interface org.apache.drill.exec.store.schedule.CompleteWork

logger

Constructor Summary

Constructors

Constructor	Description
RowGroupInfo(org.apache.hadoop.fs.Path path, long start, long length, int rowGroupIndex, long rowCount)

Method Summary

Modifier and Type	Method	Description
int	compareTo(CompleteWork o)
EndpointByteMap	getByteMap()
List<? extends MetadataBase.ColumnMetadata>	getColumns()
long	getNumRecordsToRead()
long	getRowCount()
int	getRowGroupIndex()
RowGroupReadEntry	getRowGroupReadEntry()
long	getTotalBytes()
void	setColumns(List<? extends MetadataBase.ColumnMetadata> columns)
void	setEndpointByteMap(EndpointByteMap byteMap)
void	setNumRecordsToRead(long numRecords)

Methods inherited from class org.apache.drill.exec.store.dfs.ReadEntryFromHDFS

getLength, getStart

Methods inherited from class org.apache.drill.exec.store.dfs.ReadEntryWithPath

getPath, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.store.dfs.easy.FileWork

getLength, getPath, getStart

Constructor Details

RowGroupInfo

public RowGroupInfo(org.apache.hadoop.fs.Path path,
 long start,
 long length,
 int rowGroupIndex,
 long rowCount)

Method Details

getRowGroupReadEntry

public RowGroupReadEntry getRowGroupReadEntry()

getRowGroupIndex

public int getRowGroupIndex()

compareTo

public int compareTo(CompleteWork o)

Specified by:

compareTo in interface Comparable<CompleteWork>

getTotalBytes

public long getTotalBytes()

Specified by:

getTotalBytes in interface CompleteWork

getByteMap

public EndpointByteMap getByteMap()

Specified by:

getByteMap in interface CompleteWork

getNumRecordsToRead

public long getNumRecordsToRead()

setNumRecordsToRead

public void setNumRecordsToRead(long numRecords)

setEndpointByteMap

public void setEndpointByteMap(EndpointByteMap byteMap)

getRowCount

public long getRowCount()

getColumns

public List<? extends MetadataBase.ColumnMetadata> getColumns()

setColumns

public void setColumns(List<? extends MetadataBase.ColumnMetadata> columns)