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

Class Encoder

java.lang.Object

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

Direct Known Subclasses:

BitmapEncoder, DeltaBinaryEncoder, DictionaryEncoder, FloatEncoder, GorillaEncoderV1, GorillaEncoderV2, IntZigzagEncoder, LongZigzagEncoder, PlainEncoder, RegularDataEncoder, RLBE, RleEncoder, SprintzEncoder

public abstract class Encoder
extends Object

This class is the parent class of all Encoders. Every encoder has a specific <encoderType> which represents the type of this encoder

Field Summary

Fields

Modifier and Type	Field	Description
static String	MAX_POINT_NUMBER
static String	MAX_STRING_LENGTH

Constructor Summary

Constructors

Constructor	Description
Encoder(TSEncoding type)

Method Summary

Modifier and Type	Method	Description
void	encode(boolean value, ByteArrayOutputStream out)
void	encode(double value, ByteArrayOutputStream out)
void	encode(float value, ByteArrayOutputStream out)
void	encode(int value, ByteArrayOutputStream out)
void	encode(long value, ByteArrayOutputStream out)
void	encode(short value, ByteArrayOutputStream out)
void	encode(BigDecimal value, ByteArrayOutputStream out)
void	encode(Binary value, ByteArrayOutputStream out)
abstract void	flush(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.
TSEncoding	getType()
void	setType(TSEncoding type)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_STRING_LENGTH

public static final String MAX_STRING_LENGTH

See Also:

Constant Field Values

MAX_POINT_NUMBER

public static final String MAX_POINT_NUMBER

See Also:

Constant Field Values

Constructor Detail

Encoder

public Encoder(TSEncoding type)

Method Detail

setType

public void setType(TSEncoding type)

getType

public TSEncoding getType()

encode

public void encode(boolean value,
                   ByteArrayOutputStream out)

encode

public void encode(short value,
                   ByteArrayOutputStream out)

encode

public void encode(int value,
                   ByteArrayOutputStream out)

encode

public void encode(long value,
                   ByteArrayOutputStream out)

encode

public void encode(float value,
                   ByteArrayOutputStream out)

encode

public void encode(double value,
                   ByteArrayOutputStream out)

encode

public void encode(Binary value,
                   ByteArrayOutputStream out)

encode

public void encode(BigDecimal value,
                   ByteArrayOutputStream out)

flush

public abstract void flush(ByteArrayOutputStream out)
                    throws IOException

Write all values buffered in memory cache to OutputStream.

Parameters:

out - - ByteArrayOutputStream

Throws:

IOException - cannot flush to OutputStream

getOneItemMaxSize

public int getOneItemMaxSize()

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

Returns:

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

getMaxByteSize

public long getMaxByteSize()

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

Returns:

the maximal size of possible memory occupied by current encoder