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

Class ValuePageReader

java.lang.Object

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

public class ValuePageReader
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected ByteBuffer	valueBuffer	value column in memory

Constructor Summary

Constructors

Constructor	Description
ValuePageReader(PageHeader pageHeader, ByteBuffer pageData, TSDataType dataType, Decoder valueDecoder)

Method Summary

Modifier and Type	Method	Description
void	fillIsDeleted(long[] timestamp, boolean[] isDeleted)
byte[]	getBitmap()
TSDataType	getDataType()
List<TimeRange>	getDeleteIntervalList()
Statistics	getStatistics()
protected boolean	isDeleted(long timestamp)
boolean	isModified()
BatchData	nextBatch(long[] timeBatch, boolean ascending, Filter filter)	return a BatchData with the corresponding timeBatch, the BatchData's dataType is same as this sub sensor
TsPrimitiveType	nextValue(long timestamp, int timeIndex)
TsPrimitiveType[]	nextValueBatch(long[] timeBatch)	return the value array of the corresponding time, if this sub sensor don't have a value in a time, just fill it with null
void	setDeleteIntervalList(List<TimeRange> list)
void	writeColumnBuilderWithNextBatch(int readStartIndex, int readEndIndex, ColumnBuilder columnBuilder)
void	writeColumnBuilderWithNextBatch(int readEndIndex, ColumnBuilder columnBuilder, boolean[] keepCurrentRow)
void	writeColumnBuilderWithNextBatch(int readEndIndex, ColumnBuilder columnBuilder, boolean[] keepCurrentRow, boolean[] isDeleted)

Methods inherited from class java.lang.Object

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

Field Detail

valueBuffer

protected ByteBuffer valueBuffer

value column in memory

Constructor Detail

ValuePageReader

public ValuePageReader(PageHeader pageHeader,
                       ByteBuffer pageData,
                       TSDataType dataType,
                       Decoder valueDecoder)

Method Detail

nextBatch

public BatchData nextBatch(long[] timeBatch,
                           boolean ascending,
                           Filter filter)

return a BatchData with the corresponding timeBatch, the BatchData's dataType is same as this sub sensor

nextValue

public TsPrimitiveType nextValue(long timestamp,
                                 int timeIndex)

nextValueBatch

public TsPrimitiveType[] nextValueBatch(long[] timeBatch)

return the value array of the corresponding time, if this sub sensor don't have a value in a time, just fill it with null

writeColumnBuilderWithNextBatch

public void writeColumnBuilderWithNextBatch(int readEndIndex,
                                            ColumnBuilder columnBuilder,
                                            boolean[] keepCurrentRow,
                                            boolean[] isDeleted)

writeColumnBuilderWithNextBatch

public void writeColumnBuilderWithNextBatch(int readEndIndex,
                                            ColumnBuilder columnBuilder,
                                            boolean[] keepCurrentRow)

writeColumnBuilderWithNextBatch

public void writeColumnBuilderWithNextBatch(int readStartIndex,
                                            int readEndIndex,
                                            ColumnBuilder columnBuilder)

getStatistics

public Statistics getStatistics()

setDeleteIntervalList

public void setDeleteIntervalList(List<TimeRange> list)

getDeleteIntervalList

public List<TimeRange> getDeleteIntervalList()

isModified

public boolean isModified()

isDeleted

protected boolean isDeleted(long timestamp)

fillIsDeleted

public void fillIsDeleted(long[] timestamp,
                          boolean[] isDeleted)

getDataType

public TSDataType getDataType()

getBitmap

public byte[] getBitmap()