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

Class FixedSchemaKeyedDataSerializer

java.lang.Object

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

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

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

All Implemented Interfaces:

MessageSerializer

public class FixedSchemaKeyedDataSerializer
extends KeyedDataSerializer

This serializer will be used to serialize messages with keys

Field Summary

Fields inherited from class edu.iu.dsc.tws.comms.dfw.io.BaseSerializer

MAX_SUB_MESSAGE_HEADER_SPACE, NORMAL_SUB_MESSAGE_HEADER_SIZE, sendBuffers, serializer

Constructor Summary

Constructors

Constructor and Description
FixedSchemaKeyedDataSerializer(MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
protected boolean	serializeKeyedData(java.lang.Object payload, java.lang.Object key, DataPacker dataPacker, DataPacker keyPacker, SerializeState state, DataBuffer targetBuffer) Helper method that builds the body of the message for keyed messages.

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

init, serializeSingleMessage

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

build

Methods inherited from class java.lang.Object

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

Constructor Detail

FixedSchemaKeyedDataSerializer

public FixedSchemaKeyedDataSerializer(MessageSchema messageSchema)

Method Detail

serializeKeyedData

protected boolean serializeKeyedData(java.lang.Object payload,
                                     java.lang.Object key,
                                     DataPacker dataPacker,
                                     DataPacker keyPacker,
                                     SerializeState state,
                                     DataBuffer targetBuffer)

Helper method that builds the body of the message for keyed messages.

Overrides:

serializeKeyedData in class KeyedDataSerializer

Parameters:

payload - the message that needs to be built

key - the key associated with the message

state - the state object of the message

targetBuffer - the data targetBuffer to which the built message needs to be copied

Returns:

true if the body was built and copied to the targetBuffer successfully,false otherwise.