edu.iu.dsc.tws.comms.dfw.io

Class KeyedDataDeSerializer

java.lang.Object

edu.iu.dsc.tws.comms.dfw.io.KeyedDataDeSerializer

All Implemented Interfaces:

MessageDeSerializer

Direct Known Subclasses:

FixedSchemaKeyedDataDeSerializer

public class KeyedDataDeSerializer
extends java.lang.Object
implements MessageDeSerializer

Constructor Summary

Constructors

Constructor and Description
KeyedDataDeSerializer()

Method Summary

Modifier and Type	Method and Description
void	build(java.lang.Object partialObject, int edge) Builds the message from the data buffers in the partialObject.
MessageHeader	buildHeader(DataBuffer buffer, int edge) Builds the header object from the data in the data buffer
java.lang.Object	getDataBuffers(java.lang.Object partialObject, int edge) Returns the data buffers for the given message.
void	init(Config cfg) Initialize the deserializer

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyedDataDeSerializer

public KeyedDataDeSerializer()

Method Detail

init

public void init(Config cfg)

Description copied from interface: MessageDeSerializer

Initialize the deserializer

Specified by:

init in interface MessageDeSerializer

Parameters:

cfg - configuration

build

public void build(java.lang.Object partialObject,
                  int edge)

Builds the message from the data buffers in the partialObject. Since this method supports multi-messages it iterates through the buffers and builds all the messages separately

Specified by:

build in interface MessageDeSerializer

Parameters:

partialObject - message object that needs to be built

edge - the edge value associated with this message

getDataBuffers

public java.lang.Object getDataBuffers(java.lang.Object partialObject,
                                       int edge)

Description copied from interface: MessageDeSerializer

Returns the data buffers for the given message.

Specified by:

getDataBuffers in interface MessageDeSerializer

Parameters:

partialObject - object that contains the buffers

edge - id of the edge

Returns:

if single message and not keyed returns the data. if keyed returns a pair of {key,data}. if there are multiple sub messages returns a list of data object for non keyed and a list of {key,data} for keyed operations

buildHeader

public MessageHeader buildHeader(DataBuffer buffer,
                                 int edge)

Builds the header object from the data in the data buffer

Specified by:

buildHeader in interface MessageDeSerializer

Parameters:

buffer - data buffer that contains the message

edge - the edge value associated with this message

Returns:

the built message header object