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 java.lang.Object
implements IChunkReader

Field Summary

Fields

Modifier and Type	Field	Description
protected Filter	filter

Constructor Summary

Constructors

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

Method Summary

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

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,
                          java.util.List<Chunk> valueChunkList)

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

AlignedChunkReader

public AlignedChunkReader(Chunk timeChunk,
                          java.util.List<Chunk> valueChunkList,
                          Filter filter)
                   throws java.io.IOException

constructor of ChunkReader.

Parameters:

filter - filter

Throws:

java.io.IOException

AlignedChunkReader

public AlignedChunkReader(Chunk timeChunk,
                          java.util.List<Chunk> valueChunkList,
                          Filter filter,
                          long currentTimestamp)
                   throws java.io.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:

java.io.IOException

Method Detail

pageSatisfied

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

used for value page filter

readPageData

public TsBlock readPageData(PageHeader timePageHeader,
                            java.util.List<PageHeader> valuePageHeaders,
                            java.nio.ByteBuffer compressedTimePageData,
                            java.util.List<java.nio.ByteBuffer> compressedValuePageDatas)
                     throws java.io.IOException

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

Throws:

java.io.IOException

hasNextSatisfiedPage

public boolean hasNextSatisfiedPage()

Specified by:

hasNextSatisfiedPage in interface IChunkReader

nextPageData

public BatchData nextPageData()
                       throws java.io.IOException

Specified by:

nextPageData in interface IChunkReader

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface IChunkReader

Throws:

java.io.IOException

loadPageReaderList

public java.util.List<IPageReader> loadPageReaderList()

Specified by:

loadPageReaderList in interface IChunkReader