Package org.apache.hadoop.hdfs.server.federation.store.driver.impl

Class StateStoreSerializerPBImpl

java.lang.Object

org.apache.hadoop.hdfs.server.federation.store.driver.StateStoreSerializer

org.apache.hadoop.hdfs.server.federation.store.driver.impl.StateStoreSerializerPBImpl

public final class StateStoreSerializerPBImpl
extends StateStoreSerializer

Protobuf implementation of the State Store serializer.

Method Summary

Modifier and Type	Method	Description
<T extends BaseRecord> T	deserialize(byte[] byteArray, Class<T> clazz)	Deserialize a bytes array into a record.
<T extends BaseRecord> T	deserialize(String data, Class<T> clazz)	Deserialize a string into a record.
<T> T	newRecordInstance(Class<T> clazz)	Create a new record.
byte[]	serialize(BaseRecord record)	Serialize a record into a byte array.
String	serializeString(BaseRecord record)	Serialize a record into a string.

Methods inherited from class org.apache.hadoop.hdfs.server.federation.store.driver.StateStoreSerializer

getSerializer, getSerializer, newRecord

Methods inherited from class java.lang.Object

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

Method Details

newRecordInstance

public <T> T newRecordInstance(Class<T> clazz)

Description copied from class: StateStoreSerializer

Create a new record.

Specified by:

newRecordInstance in class StateStoreSerializer

Type Parameters:

T - Type of the record.

Parameters:

clazz - Class of the new record.

Returns:

New record.

serialize

public byte[] serialize(BaseRecord record)

Description copied from class: StateStoreSerializer

Serialize a record into a byte array.

Specified by:

serialize in class StateStoreSerializer

Parameters:

record - Record to serialize.

Returns:

Byte array with the serialized record.

serializeString

public String serializeString(BaseRecord record)

Description copied from class: StateStoreSerializer

Serialize a record into a string.

Specified by:

serializeString in class StateStoreSerializer

Parameters:

record - Record to serialize.

Returns:

String with the serialized record.

deserialize

public <T extends BaseRecord> T deserialize(byte[] byteArray,
 Class<T> clazz)
                                     throws IOException

Description copied from class: StateStoreSerializer

Deserialize a bytes array into a record.

Specified by:

deserialize in class StateStoreSerializer

Type Parameters:

T - Type of the record.

Parameters:

byteArray - Byte array to deserialize.

clazz - Class of the record.

Returns:

New record.

Throws:

IOException - If it cannot deserialize the record.

deserialize

public <T extends BaseRecord> T deserialize(String data,
 Class<T> clazz)
                                     throws IOException

Description copied from class: StateStoreSerializer

Deserialize a string into a record.

Specified by:

deserialize in class StateStoreSerializer

Type Parameters:

T - Type of the record.

Parameters:

data - String with the data to deserialize.

clazz - Class of the record.

Returns:

New record.

Throws:

IOException - If it cannot deserialize the record.