Package org.apache.iotdb.tsfile.read.reader.chunk

Class ChunkReader

java.lang.Object

org.apache.iotdb.tsfile.read.reader.chunk.ChunkReader

All Implemented Interfaces:

IChunkReader

public class ChunkReader
extends Object
implements IChunkReader

Field Summary

Fields

Modifier and Type	Field	Description
protected Filter	filter

Constructor Summary

Constructors

Constructor	Description
ChunkReader(Chunk chunk)	Constructor of ChunkReader without deserializing chunk into page.
ChunkReader(Chunk chunk, Filter filter)	constructor of ChunkReader.
ChunkReader(Chunk chunk, Filter filter, long currentTimestamp)	Constructor of ChunkReader by timestamp.

Method Summary

Modifier and Type	Method	Description
void	close()
ChunkHeader	getChunkHeader()
boolean	hasNextSatisfiedPage()	judge if has next page whose page header satisfies the filter.
List<IPageReader>	loadPageReaderList()
BatchData	nextPageData()	get next data batch.
protected boolean	pageSatisfied(PageHeader pageHeader)
TsBlock	readPageData(PageHeader pageHeader, ByteBuffer compressedPageData)	Read data from compressed page data.
ByteBuffer	readPageDataWithoutUncompressing(PageHeader pageHeader)	Read page data without uncompressing it.

Methods inherited from class java.lang.Object

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

Field Detail

filter

protected Filter filter

Constructor Detail

ChunkReader

public ChunkReader(Chunk chunk,
                   Filter filter)
            throws IOException

constructor of ChunkReader.

Parameters:

chunk - input Chunk object

filter - filter

Throws:

IOException

ChunkReader

public ChunkReader(Chunk chunk,
                   Filter filter,
                   long currentTimestamp)
            throws IOException

Constructor of ChunkReader by timestamp. This constructor is used to accelerate queries by filtering out pages whose endTime is less than current timestamp.

Throws:

IOException

ChunkReader

public ChunkReader(Chunk chunk)

Constructor of ChunkReader without deserializing chunk into page. This is used for fast compaction.

Method Detail

hasNextSatisfiedPage

public boolean hasNextSatisfiedPage()

judge if has next page whose page header satisfies the filter.

Specified by:

hasNextSatisfiedPage in interface IChunkReader

nextPageData

public BatchData nextPageData()
                       throws IOException

get next data batch.

Specified by:

nextPageData in interface IChunkReader

Returns:

next data batch

Throws:

IOException - IOException

pageSatisfied

protected boolean pageSatisfied(PageHeader pageHeader)

readPageDataWithoutUncompressing

public ByteBuffer readPageDataWithoutUncompressing(PageHeader pageHeader)
                                            throws IOException

Read page data without uncompressing it.

Returns:

compressed page data

Throws:

IOException

readPageData

public TsBlock readPageData(PageHeader pageHeader,
                            ByteBuffer compressedPageData)
                     throws IOException

Read data from compressed page data. Uncompress the page and decode it to batch data.

Parameters:

compressedPageData - Compressed page data

Throws:

IOException

close

public void close()

Specified by:

close in interface IChunkReader

getChunkHeader

public ChunkHeader getChunkHeader()

loadPageReaderList

public List<IPageReader> loadPageReaderList()

Specified by:

loadPageReaderList in interface IChunkReader