Package org.apache.iotdb.tsfile.file.header

Class ChunkHeader

java.lang.Object

org.apache.iotdb.tsfile.file.header.ChunkHeader

public class ChunkHeader
extends Object

Constructor Summary

Constructors

Constructor	Description
ChunkHeader(byte chunkType, String measurementID, int dataSize, int headerSize, TSDataType dataType, CompressionType compressionType, TSEncoding encoding)
ChunkHeader(byte chunkType, String measurementID, int dataSize, TSDataType dataType, CompressionType compressionType, TSEncoding encoding)
ChunkHeader(String measurementID, int dataSize, TSDataType dataType, CompressionType compressionType, TSEncoding encoding, int numOfPages)
ChunkHeader(String measurementID, int dataSize, TSDataType dataType, CompressionType compressionType, TSEncoding encoding, int numOfPages, int mask)

Method Summary

Modifier and Type	Method	Description
static Pair<CompressionType,TSEncoding>	deserializeCompressionTypeAndEncoding(InputStream inputStream)	Used by TsFileSequenceReader.readTimeseriesCompressionTypeAndEncoding(TimeseriesMetadata) to only decode data size, CompressionType and TSEncoding.
static ChunkHeader	deserializeFrom(InputStream inputStream, byte chunkType)	deserialize from inputStream, the marker has already been read.
static ChunkHeader	deserializeFrom(TsFileInput input, long offset, int chunkHeaderSize)	deserialize from TsFileInput, the marker has not been read.
byte	getChunkType()
CompressionType	getCompressionType()
int	getDataSize()
TSDataType	getDataType()
TSEncoding	getEncodingType()
String	getMeasurementID()
int	getNumOfPages()
int	getSerializedSize()
static int	getSerializedSize(String measurementID)	The estimated serialized size of chunk header.
static int	getSerializedSize(String measurementID, int dataSize)	the exact serialized size of chunk header.
void	increasePageNums(int i)
void	mergeChunkHeader(ChunkHeader chunkHeader)
int	serializeTo(OutputStream outputStream)	serialize to outputStream.
int	serializeTo(ByteBuffer buffer)	serialize to ByteBuffer.
void	setChunkType(byte chunkType)
void	setDataSize(int dataSize)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ChunkHeader

public ChunkHeader(String measurementID,
                   int dataSize,
                   TSDataType dataType,
                   CompressionType compressionType,
                   TSEncoding encoding,
                   int numOfPages)

ChunkHeader

public ChunkHeader(String measurementID,
                   int dataSize,
                   TSDataType dataType,
                   CompressionType compressionType,
                   TSEncoding encoding,
                   int numOfPages,
                   int mask)

ChunkHeader

public ChunkHeader(byte chunkType,
                   String measurementID,
                   int dataSize,
                   TSDataType dataType,
                   CompressionType compressionType,
                   TSEncoding encoding)

ChunkHeader

public ChunkHeader(byte chunkType,
                   String measurementID,
                   int dataSize,
                   int headerSize,
                   TSDataType dataType,
                   CompressionType compressionType,
                   TSEncoding encoding)

Method Detail

getSerializedSize

public static int getSerializedSize(String measurementID,
                                    int dataSize)

the exact serialized size of chunk header.

getSerializedSize

public static int getSerializedSize(String measurementID)

The estimated serialized size of chunk header. Only used when we don't know the actual dataSize attribute

getSerializedSize

public int getSerializedSize()

deserializeFrom

public static ChunkHeader deserializeFrom(InputStream inputStream,
                                          byte chunkType)
                                   throws IOException

deserialize from inputStream, the marker has already been read.

Returns:

ChunkHeader the ChunkHeader read from inputStream

Throws:

IOException - exception when reading stream

deserializeFrom

public static ChunkHeader deserializeFrom(TsFileInput input,
                                          long offset,
                                          int chunkHeaderSize)
                                   throws IOException

deserialize from TsFileInput, the marker has not been read.

Parameters:

input - TsFileInput

offset - offset

chunkHeaderSize - the estimated size of chunk's header

Returns:

CHUNK_HEADER object

Throws:

IOException - IOException

deserializeCompressionTypeAndEncoding

public static Pair<CompressionType,TSEncoding> deserializeCompressionTypeAndEncoding(InputStream inputStream)
                                                                                    throws IOException

Used by TsFileSequenceReader.readTimeseriesCompressionTypeAndEncoding(TimeseriesMetadata) to only decode data size, CompressionType and TSEncoding.

Parameters:

inputStream - input stream

Returns:

- Compression type and encoding.

Throws:

IOException - - If an I/O error occurs.

getMeasurementID

public String getMeasurementID()

getDataSize

public int getDataSize()

getDataType

public TSDataType getDataType()

serializeTo

public int serializeTo(OutputStream outputStream)
                throws IOException

serialize to outputStream.

Parameters:

outputStream - outputStream

Returns:

length

Throws:

IOException - IOException

serializeTo

public int serializeTo(ByteBuffer buffer)

serialize to ByteBuffer.

Parameters:

buffer - ByteBuffer

Returns:

length

getNumOfPages

public int getNumOfPages()

getCompressionType

public CompressionType getCompressionType()

getEncodingType

public TSEncoding getEncodingType()

toString

public String toString()

Overrides:

toString in class Object

mergeChunkHeader

public void mergeChunkHeader(ChunkHeader chunkHeader)

setDataSize

public void setDataSize(int dataSize)

getChunkType

public byte getChunkType()

setChunkType

public void setChunkType(byte chunkType)

increasePageNums

public void increasePageNums(int i)