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

Class FixedSchemaKeyedDataDeSerializer

java.lang.Object

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

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

All Implemented Interfaces:

MessageDeSerializer

public class FixedSchemaKeyedDataDeSerializer
extends KeyedDataDeSerializer

Constructor Summary

Constructors

Constructor and Description
FixedSchemaKeyedDataDeSerializer(MessageSchema messageSchema)

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.

Methods inherited from class edu.iu.dsc.tws.comms.dfw.io.KeyedDataDeSerializer

buildHeader, getDataBuffers, init

Methods inherited from class java.lang.Object

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

Constructor Detail

FixedSchemaKeyedDataDeSerializer

public FixedSchemaKeyedDataDeSerializer(MessageSchema messageSchema)

Method Detail

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

Overrides:

build in class KeyedDataDeSerializer

Parameters:

partialObject - message object that needs to be built

edge - the edge value associated with this message