edu.iu.dsc.tws.api.comms.packing

Interface MessageDeSerializer

All Known Implementing Classes:

DataDeserializer, FixedSchemaDataDeserializer, FixedSchemaKeyedDataDeSerializer, KeyedDataDeSerializer

public interface MessageDeSerializer

Message un-packing interface.

Method Summary

Modifier and Type	Method and Description
void	build(java.lang.Object partialObject, int edge) Serilize a message
MessageHeader	buildHeader(DataBuffer buffer, int edge) Read the header from the 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

Method Detail

init

void init(Config cfg)

Initialize the deserializer

Parameters:

cfg - configuration

build

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

Serilize a message

Parameters:

partialObject - the outmessage

edge - the edge

buildHeader

MessageHeader buildHeader(DataBuffer buffer,
                          int edge)

Read the header from the buffer

Parameters:

buffer - the buffer to read

edge - edge

Returns:

a message header

getDataBuffers

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

Returns the data buffers for the given message.

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