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

Class AlignedChunkReader

java.lang.Object

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

All Implemented Interfaces:

IChunkReader

public class AlignedChunkReader
extends Object
implements IChunkReader

Field Summary

Fields

Modifier and Type	Field	Description
protected Filter	filter

Constructor Summary

Constructors

Constructor	Description
AlignedChunkReader(Chunk timeChunk, List<Chunk> valueChunkList)	Constructor of ChunkReader without deserializing chunk into page.
AlignedChunkReader(Chunk timeChunk, List<Chunk> valueChunkList, Filter filter, boolean queryAllSensors)	constructor of ChunkReader.
AlignedChunkReader(Chunk timeChunk, List<Chunk> valueChunkList, Filter filter, long currentTimestamp)	Constructor of ChunkReader by timestamp.

Method Summary

Modifier and Type	Method	Description
void	close()
IPointReader	getPagePointReader(PageHeader timePageHeader, List<PageHeader> valuePageHeaders, ByteBuffer compressedTimePageData, List<ByteBuffer> compressedValuePageDatas)	Read data from compressed page data.
boolean	hasNextSatisfiedPage()
List<IPageReader>	loadPageReaderList()
BatchData	nextPageData()
protected boolean	pageSatisfied(PageHeader pageHeader, List<TimeRange> valueDeleteInterval)	used for value page filter

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

AlignedChunkReader

public AlignedChunkReader(Chunk timeChunk,
                          List<Chunk> valueChunkList)

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

AlignedChunkReader

public AlignedChunkReader(Chunk timeChunk,
                          List<Chunk> valueChunkList,
                          Filter filter,
                          boolean queryAllSensors)
                   throws IOException

constructor of ChunkReader.

Parameters:

filter - filter

Throws:

IOException

AlignedChunkReader

public AlignedChunkReader(Chunk timeChunk,
                          List<Chunk> valueChunkList,
                          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

Method Detail

pageSatisfied

protected boolean pageSatisfied(PageHeader pageHeader,
                                List<TimeRange> valueDeleteInterval)

used for value page filter

getPagePointReader

public IPointReader getPagePointReader(PageHeader timePageHeader,
                                       List<PageHeader> valuePageHeaders,
                                       ByteBuffer compressedTimePageData,
                                       List<ByteBuffer> compressedValuePageDatas)
                                throws IOException

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

Throws:

IOException

hasNextSatisfiedPage

public boolean hasNextSatisfiedPage()

Specified by:

hasNextSatisfiedPage in interface IChunkReader

nextPageData

public BatchData nextPageData()
                       throws IOException

Specified by:

nextPageData in interface IChunkReader

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface IChunkReader

Throws:

IOException

loadPageReaderList

public List<IPageReader> loadPageReaderList()

Specified by:

loadPageReaderList in interface IChunkReader