Package org.apache.iotdb.tsfile.file.metadata

Class ChunkMetadata

java.lang.Object

org.apache.iotdb.tsfile.file.metadata.ChunkMetadata

All Implemented Interfaces:

IChunkMetadata

public class ChunkMetadata
extends Object
implements IChunkMetadata

Metadata of one chunk.

Constructor Summary

Constructors

Constructor	Description
ChunkMetadata()
ChunkMetadata(String measurementUid, TSDataType tsDataType, long fileOffset, Statistics<? extends Serializable> statistics)	constructor of ChunkMetaData.
ChunkMetadata(ChunkMetadata other)

Method Summary

Modifier and Type	Method	Description
long	calculateRamSize()
static long	calculateRamSize(String measurementId, TSDataType dataType)
static ChunkMetadata	deserializeFrom(ByteBuffer buffer, TSDataType dataType)
static ChunkMetadata	deserializeFrom(ByteBuffer buffer, TimeseriesMetadata timeseriesMetadata)	deserialize from ByteBuffer.
boolean	equals(Object o)
IChunkLoader	getChunkLoader()
TSDataType	getDataType()
List<TimeRange>	getDeleteIntervalList()
long	getEndTime()
String	getFilePath()
byte	getMask()
String	getMeasurementUid()
long	getNumOfPoints()
long	getOffsetOfChunkHeader()	get offset of chunk header.
long	getStartTime()
Statistics<? extends Serializable>	getStatistics()
long	getVersion()
int	hashCode()
void	insertIntoSortedDeletions(TimeRange timeRange)
boolean	isClosed()
boolean	isModified()
boolean	isSeq()
void	mergeChunkMetadata(ChunkMetadata chunkMetadata)
boolean	needSetChunkLoader()
int	serializeTo(OutputStream outputStream, boolean serializeStatistic)	serialize to outputStream.
void	setChunkLoader(IChunkLoader chunkLoader)
void	setClosed(boolean closed)
void	setFilePath(String filePath)
void	setMask(byte mask)
void	setModified(boolean modified)
void	setSeq(boolean seq)
void	setVersion(long version)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ChunkMetadata

public ChunkMetadata()

ChunkMetadata

public ChunkMetadata(String measurementUid,
                     TSDataType tsDataType,
                     long fileOffset,
                     Statistics<? extends Serializable> statistics)

constructor of ChunkMetaData.

Parameters:

measurementUid - measurement id

tsDataType - time series data type

fileOffset - file offset

statistics - value statistics

ChunkMetadata

public ChunkMetadata(ChunkMetadata other)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getNumOfPoints

public long getNumOfPoints()

getOffsetOfChunkHeader

public long getOffsetOfChunkHeader()

get offset of chunk header.

Specified by:

getOffsetOfChunkHeader in interface IChunkMetadata

Returns:

Byte offset of header of this chunk (includes the marker)

getMeasurementUid

public String getMeasurementUid()

Specified by:

getMeasurementUid in interface IChunkMetadata

getStatistics

public Statistics<? extends Serializable> getStatistics()

Specified by:

getStatistics in interface IChunkMetadata

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface IChunkMetadata

getEndTime

public long getEndTime()

Specified by:

getEndTime in interface IChunkMetadata

getDataType

public TSDataType getDataType()

Specified by:

getDataType in interface IChunkMetadata

serializeTo

public int serializeTo(OutputStream outputStream,
                       boolean serializeStatistic)
                throws IOException

serialize to outputStream.

Specified by:

serializeTo in interface IChunkMetadata

Parameters:

outputStream - outputStream

Returns:

length

Throws:

IOException - IOException

deserializeFrom

public static ChunkMetadata deserializeFrom(ByteBuffer buffer,
                                            TimeseriesMetadata timeseriesMetadata)

deserialize from ByteBuffer.

Parameters:

buffer - ByteBuffer

Returns:

ChunkMetaData object

deserializeFrom

public static ChunkMetadata deserializeFrom(ByteBuffer buffer,
                                            TSDataType dataType)

getVersion

public long getVersion()

Specified by:

getVersion in interface IChunkMetadata

setVersion

public void setVersion(long version)

Specified by:

setVersion in interface IChunkMetadata

getDeleteIntervalList

public List<TimeRange> getDeleteIntervalList()

Specified by:

getDeleteIntervalList in interface IChunkMetadata

insertIntoSortedDeletions

public void insertIntoSortedDeletions(TimeRange timeRange)

Specified by:

insertIntoSortedDeletions in interface IChunkMetadata

getChunkLoader

public IChunkLoader getChunkLoader()

Specified by:

getChunkLoader in interface IChunkMetadata

needSetChunkLoader

public boolean needSetChunkLoader()

Specified by:

needSetChunkLoader in interface IChunkMetadata

setChunkLoader

public void setChunkLoader(IChunkLoader chunkLoader)

Specified by:

setChunkLoader in interface IChunkMetadata

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

isModified

public boolean isModified()

Specified by:

isModified in interface IChunkMetadata

setModified

public void setModified(boolean modified)

Specified by:

setModified in interface IChunkMetadata

calculateRamSize

public long calculateRamSize()

calculateRamSize

public static long calculateRamSize(String measurementId,
                                    TSDataType dataType)

mergeChunkMetadata

public void mergeChunkMetadata(ChunkMetadata chunkMetadata)

setSeq

public void setSeq(boolean seq)

Specified by:

setSeq in interface IChunkMetadata

isSeq

public boolean isSeq()

Specified by:

isSeq in interface IChunkMetadata

isClosed

public boolean isClosed()

setClosed

public void setClosed(boolean closed)

Specified by:

setClosed in interface IChunkMetadata

getFilePath

public String getFilePath()

setFilePath

public void setFilePath(String filePath)

Specified by:

setFilePath in interface IChunkMetadata

getMask

public byte getMask()

Specified by:

getMask in interface IChunkMetadata

setMask

public void setMask(byte mask)