public static final class Serializer.CompressionWrapper<E> extends Object implements Serializer<E>, Serializable
Serializer.CompressionWrapper<E>
Modifier and Type | Field and Description |
---|---|
protected ThreadLocal<CompressLZF> |
LZF |
protected Serializer<E> |
serializer |
BASIC, BOOLEAN, BYTE_ARRAY, BYTE_ARRAY_NOSIZE, CHAR_ARRAY, DOUBLE_ARRAY, ILLEGAL_ACCESS, INT_ARRAY, INTEGER, JAVA, LONG, LONG_ARRAY, STRING, STRING_ASCII, STRING_INTERN, STRING_NOSIZE, UUID
Modifier | Constructor and Description |
---|---|
|
CompressionWrapper(Serializer<E> serializer) |
protected |
CompressionWrapper(SerializerBase serializerBase,
DataInput is,
SerializerBase.FastArrayList<Object> objectStack)
used for deserialization
|
Modifier and Type | Method and Description |
---|---|
E |
deserialize(DataInput in,
int available)
Deserialize the content of an object from a DataInput.
|
boolean |
equals(Object o) |
int |
fixedSize()
Data could be serialized into record with variable size or fixed size.
|
int |
hashCode() |
void |
serialize(DataOutput out,
E value)
Serialize the content of an object into a ObjectOutput
|
protected final Serializer<E> serializer
protected final ThreadLocal<CompressLZF> LZF
public CompressionWrapper(Serializer<E> serializer)
protected CompressionWrapper(SerializerBase serializerBase, DataInput is, SerializerBase.FastArrayList<Object> objectStack) throws IOException
IOException
public void serialize(DataOutput out, E value) throws IOException
Serializer
serialize
in interface Serializer<E>
out
- ObjectOutput to save object intovalue
- Object to serializeIOException
public E deserialize(DataInput in, int available) throws IOException
Serializer
deserialize
in interface Serializer<E>
in
- to read serialized data fromavailable
- how many bytes are available in DataInput for reading, may be -1 (in streams) or 0 (null).IOException
public int fixedSize()
Serializer
fixedSize
in interface Serializer<E>
Copyright © 2017. All rights reserved.