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

Class LongSprintzEncoder

java.lang.Object

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

org.apache.iotdb.tsfile.encoding.encoder.SprintzEncoder

org.apache.iotdb.tsfile.encoding.encoder.LongSprintzEncoder

public class LongSprintzEncoder
extends SprintzEncoder

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.Vector<java.lang.Long>	values

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

bitWidth, Block_size, byteCache, config, groupMax, groupNum, isFirstCached, logger, predictMethod

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

MAX_POINT_NUMBER, MAX_STRING_LENGTH

Constructor Summary

Constructors

Constructor	Description
LongSprintzEncoder()

Method Summary

Modifier and Type	Method	Description
protected void	bitPack()
protected java.lang.Long	delta(java.lang.Long value, java.lang.Long preValue)
void	encode(long value, java.io.ByteArrayOutputStream out)
protected java.lang.Long	fire(java.lang.Long value, java.lang.Long preValue)
void	flush(java.io.ByteArrayOutputStream out)	Write all values buffered in memory cache to 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 java.lang.Long	predict(java.lang.Long value, java.lang.Long preVlaue)
protected void	reset()

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

encode, encode, encode, encode, encode, encode, encode, getType, setType

Methods inherited from class java.lang.Object

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

Field Detail

values

protected java.util.Vector<java.lang.Long> values

Constructor Detail

LongSprintzEncoder

public LongSprintzEncoder()

Method Detail

reset

protected void reset()

Overrides:

reset in class SprintzEncoder

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

predict

protected java.lang.Long predict(java.lang.Long value,
                                 java.lang.Long preVlaue)
                          throws TsFileEncodingException

Throws:

TsFileEncodingException

bitPack

protected void bitPack()
                throws java.io.IOException

Specified by:

bitPack in class SprintzEncoder

Throws:

java.io.IOException

delta

protected java.lang.Long delta(java.lang.Long value,
                               java.lang.Long preValue)

fire

protected java.lang.Long fire(java.lang.Long value,
                              java.lang.Long preValue)

flush

public void flush(java.io.ByteArrayOutputStream out)
           throws java.io.IOException

Description copied from class: Encoder

Write all values buffered in memory cache to OutputStream.

Specified by:

flush in class Encoder

Parameters:

out - - ByteArrayOutputStream

Throws:

java.io.IOException - cannot flush to OutputStream

encode

public void encode(long value,
                   java.io.ByteArrayOutputStream out)

Overrides:

encode in class Encoder