com.linkedin.paldb.impl

Class StorageSerialization

java.lang.Object

com.linkedin.paldb.impl.StorageSerialization

public final class StorageSerialization
extends java.lang.Object

Internal serialization implementation.

Constructor Summary

Constructors

Constructor and Description
StorageSerialization(Configuration config) Default constructor with configuration.

Method Summary

Modifier and Type	Method and Description
java.lang.Object	deserialize(byte[] buf)
java.lang.Object	deserialize(java.io.DataInput is)
boolean	isCompressionEnabled() Returns true if compression is enabled.
byte[]	serializeKey(java.lang.Object key) Serializes the key object and returns it as a byte array.
void	serializeKey(java.lang.Object key, java.io.DataOutput dataOutput) Serializes the key and writes it into dataOutput.
byte[]	serializeValue(java.lang.Object value) Serializes the value object and returns it as a byte array.
void	serializeValue(java.lang.Object value, java.io.DataOutput dataOutput) Serializes the value and writes it into dataOutput.

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageSerialization

public StorageSerialization(Configuration config)

Default constructor with configuration.

Uses Configuration.COMPRESSION_ENABLED and Configuration.KEY_COMPARATOR values from the configuration.

Parameters:

config - configuration

Method Detail

serializeKey

public byte[] serializeKey(java.lang.Object key)
                    throws java.io.IOException

Serializes the key object and returns it as a byte array.

Parameters:

key - key to serialize

Returns:

key as byte array

Throws:

java.io.IOException - if an io error occurs

serializeKey

public void serializeKey(java.lang.Object key,
                         java.io.DataOutput dataOutput)
                  throws java.io.IOException

Serializes the key and writes it into dataOutput.

Parameters:

key - key to serialize

dataOutput - data output

Throws:

java.io.IOException - if an io error occurs

serializeValue

public byte[] serializeValue(java.lang.Object value)
                      throws java.io.IOException

Serializes the value object and returns it as a byte array.

Parameters:

value - value to serialize

Returns:

value as byte array

Throws:

java.io.IOException - if an io error occurs

serializeValue

public void serializeValue(java.lang.Object value,
                           java.io.DataOutput dataOutput)
                    throws java.io.IOException

Serializes the value and writes it into dataOutput.

Parameters:

value - value to serialize

dataOutput - data output

Throws:

java.io.IOException - if an io error occurs

isCompressionEnabled

public boolean isCompressionEnabled()

Returns true if compression is enabled.

Returns:

true if enabled, false otherwise

deserialize

public java.lang.Object deserialize(byte[] buf)
                             throws java.lang.ClassNotFoundException,
                                    java.io.IOException

Throws:

java.lang.ClassNotFoundException

java.io.IOException

deserialize

public java.lang.Object deserialize(java.io.DataInput is)
                             throws java.io.IOException,
                                    java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException