Package org.apache.iotdb.tsfile.encoding.encoder

Class IntRleEncoder

java.lang.Object

org.apache.iotdb.tsfile.encoding.encoder.Encoder

org.apache.iotdb.tsfile.encoding.encoder.RleEncoder<Integer>

org.apache.iotdb.tsfile.encoding.encoder.IntRleEncoder

public class IntRleEncoder
extends RleEncoder<Integer>

Encoder for int value using rle or bit-packing.

Field Summary

Fields inherited from class org.apache.iotdb.tsfile.encoding.encoder.RleEncoder

bitPackedGroupCount, bitWidth, bufferedValues, byteCache, bytesBuffer, config, isBitPackRun, isBitWidthSaved, numBufferedValues, preValue, repeatCount, values

Fields inherited from class org.apache.iotdb.tsfile.encoding.encoder.Encoder

MAX_POINT_NUMBER, MAX_STRING_LENGTH

Constructor Summary

Constructors

Constructor	Description
IntRleEncoder()

Method Summary

Modifier and Type	Method	Description
protected void	clearBuffer()	clean all useless value in bufferedValues and set 0.
protected void	convertBuffer()
void	encode(boolean value, ByteArrayOutputStream out)
void	encode(int value, ByteArrayOutputStream out)
void	flush(ByteArrayOutputStream out)	write all values buffered in the cache to an OutputStream.
long	getMaxByteSize()	The maximal possible memory size occupied by current Encoder.
int	getOneItemMaxSize()	When encoder accepts a new incoming data point, the maximal possible size in byte it takes to store in memory.
protected void	reset()
protected void	writeRleRun()	write bytes to an outputStream using rle format: [header][value].

Methods inherited from class org.apache.iotdb.tsfile.encoding.encoder.RleEncoder

encode, encode, encode, encode, encode, encode, encodeValue, endPreviousBitPackedRun, writeOrAppendBitPackedRun

Methods inherited from class org.apache.iotdb.tsfile.encoding.encoder.Encoder

getType, setType

Methods inherited from class java.lang.Object

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

Constructor Detail

IntRleEncoder

public IntRleEncoder()

Method Detail

encode

public void encode(int value,
                   ByteArrayOutputStream out)

Overrides:

encode in class RleEncoder<Integer>

encode

public void encode(boolean value,
                   ByteArrayOutputStream out)

Overrides:

encode in class RleEncoder<Integer>

flush

public void flush(ByteArrayOutputStream out)
           throws IOException

write all values buffered in the cache to an OutputStream.

Overrides:

flush in class RleEncoder<Integer>

Parameters:

out - - byteArrayOutputStream

Throws:

IOException - cannot flush to OutputStream

reset

protected void reset()

Overrides:

reset in class RleEncoder<Integer>

writeRleRun

protected void writeRleRun()
                    throws IOException

write bytes to an outputStream using rle format: [header][value].

Specified by:

writeRleRun in class RleEncoder<Integer>

Throws:

IOException - cannot write RLE run

clearBuffer

protected void clearBuffer()

Description copied from class: RleEncoder

clean all useless value in bufferedValues and set 0.

Specified by:

clearBuffer in class RleEncoder<Integer>

convertBuffer

protected void convertBuffer()

Specified by:

convertBuffer in class RleEncoder<Integer>

getOneItemMaxSize

public int getOneItemMaxSize()

Description copied from class: Encoder

When encoder accepts a new incoming data point, the maximal possible size in byte it takes to store in memory.

Overrides:

getOneItemMaxSize in class Encoder

Returns:

the maximal possible size of one data item encoded by this encoder

getMaxByteSize

public long getMaxByteSize()

Description copied from class: Encoder

The maximal possible memory size occupied by current Encoder. This statistic value doesn't involve OutputStream.

Overrides:

getMaxByteSize in class Encoder

Returns:

the maximal size of possible memory occupied by current encoder