com.yahoo.bullet.pubsub

Class IdentityPubSubMessageSerDe

java.lang.Object

com.yahoo.bullet.pubsub.PubSubMessageSerDe

com.yahoo.bullet.pubsub.IdentityPubSubMessageSerDe

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

ByteArrayPubSubMessageSerDe

public class IdentityPubSubMessageSerDe
extends PubSubMessageSerDe

See Also:

Serialized Form

Field Summary

Fields inherited from class com.yahoo.bullet.pubsub.PubSubMessageSerDe

config

Constructor Summary

Constructors

Constructor and Description
IdentityPubSubMessageSerDe(BulletConfig config) Constructor.

Method Summary

Modifier and Type	Method and Description
PubSubMessage	fromMessage(PubSubMessage message) Takes a converted PubSubMessage and returns the original format of the message.
PubSubMessage	toMessage(PubSubMessage message) Takes a PubSubMessage and returns the new format of the message.

Methods inherited from class com.yahoo.bullet.pubsub.PubSubMessageSerDe

from, toMessage

Methods inherited from class java.lang.Object

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

Constructor Detail

IdentityPubSubMessageSerDe

public IdentityPubSubMessageSerDe(BulletConfig config)

Constructor.

Parameters:

config - The BulletConfig to configure this class.

Method Detail

toMessage

public PubSubMessage toMessage(PubSubMessage message)

Description copied from class: PubSubMessageSerDe

Takes a PubSubMessage and returns the new format of the message. Note that it is allowed to modify the original message. See PubSubMessageSerDe.fromMessage(PubSubMessage) for the inverse.

Specified by:

toMessage in class PubSubMessageSerDe

Parameters:

message - The PubSubMessage to convert.

Returns:

A converted PubSubMessage.

fromMessage

public PubSubMessage fromMessage(PubSubMessage message)

Description copied from class: PubSubMessageSerDe

Takes a converted PubSubMessage and returns the original format of the message. Note that it is allowed to modify the original message. See PubSubMessageSerDe.toMessage(PubSubMessage) for the inverse.

Specified by:

fromMessage in class PubSubMessageSerDe

Parameters:

message - The PubSubMessage to revert.

Returns:

A reverted PubSubMessage.