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

Class PageReader

java.lang.Object

org.apache.iotdb.tsfile.read.reader.page.PageReader

All Implemented Interfaces:

IPageReader

public class PageReader
extends Object
implements IPageReader

Field Summary

Fields

Modifier and Type	Field	Description
protected TSDataType	dataType
protected Filter	filter
protected ByteBuffer	timeBuffer	time column in memory
protected Decoder	timeDecoder	decoder for time column
protected ByteBuffer	valueBuffer	value column in memory
protected Decoder	valueDecoder	decoder for value column

Constructor Summary

Constructors

Constructor	Description
PageReader(ByteBuffer pageData, TSDataType dataType, Decoder valueDecoder, Decoder timeDecoder, Filter filter)
PageReader(PageHeader pageHeader, ByteBuffer pageData, TSDataType dataType, Decoder valueDecoder, Decoder timeDecoder, Filter filter)

Method Summary

Modifier and Type	Method	Description
TsBlock	getAllSatisfiedData()
BatchData	getAllSatisfiedPageData(boolean ascending)
List<TimeRange>	getDeleteIntervalList()
Statistics<? extends Serializable>	getStatistics()
void	initTsBlockBuilder(List<TSDataType> dataTypes)
protected boolean	isDeleted(long timestamp)
boolean	isModified()
void	setDeleteIntervalList(List<TimeRange> list)
void	setFilter(Filter filter)
void	setLimitOffset(PaginationController paginationController)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iotdb.tsfile.read.reader.IPageReader

getAllSatisfiedPageData

Field Detail

dataType

protected TSDataType dataType

valueDecoder

protected Decoder valueDecoder

decoder for value column

timeDecoder

protected Decoder timeDecoder

decoder for time column

timeBuffer

protected ByteBuffer timeBuffer

time column in memory

valueBuffer

protected ByteBuffer valueBuffer

value column in memory

filter

protected Filter filter

Constructor Detail

PageReader

public PageReader(ByteBuffer pageData,
                  TSDataType dataType,
                  Decoder valueDecoder,
                  Decoder timeDecoder,
                  Filter filter)

PageReader

public PageReader(PageHeader pageHeader,
                  ByteBuffer pageData,
                  TSDataType dataType,
                  Decoder valueDecoder,
                  Decoder timeDecoder,
                  Filter filter)

Method Detail

getAllSatisfiedPageData

public BatchData getAllSatisfiedPageData(boolean ascending)
                                  throws IOException

Specified by:

getAllSatisfiedPageData in interface IPageReader

Returns:

the returned BatchData may be empty, but never be null

Throws:

IOException

getAllSatisfiedData

public TsBlock getAllSatisfiedData()
                            throws IOException

Specified by:

getAllSatisfiedData in interface IPageReader

Throws:

IOException

getStatistics

public Statistics<? extends Serializable> getStatistics()

Specified by:

getStatistics in interface IPageReader

setFilter

public void setFilter(Filter filter)

Specified by:

setFilter in interface IPageReader

setLimitOffset

public void setLimitOffset(PaginationController paginationController)

Specified by:

setLimitOffset in interface IPageReader

setDeleteIntervalList

public void setDeleteIntervalList(List<TimeRange> list)

getDeleteIntervalList

public List<TimeRange> getDeleteIntervalList()

isModified

public boolean isModified()

Specified by:

isModified in interface IPageReader

initTsBlockBuilder

public void initTsBlockBuilder(List<TSDataType> dataTypes)

Specified by:

initTsBlockBuilder in interface IPageReader

isDeleted

protected boolean isDeleted(long timestamp)