org.apache.storm.eventhubs.spout

Class EventDataScheme

java.lang.Object

org.apache.storm.eventhubs.spout.EventDataScheme

All Implemented Interfaces:

Serializable, IEventDataScheme

public class EventDataScheme
extends Object
implements IEventDataScheme

An Event Data Scheme which deserializes message payload into the Strings. No encoding is assumed. The receiver will need to handle parsing of the string data in appropriate encoding.

The resulting tuple would contain two items: the the message string, and a map of properties that include metadata, which can be used to determine who processes the message, and how it is processed.

For passing the raw bytes of a messsage to Bolts, refer to BinaryEventDataScheme.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
EventDataScheme()

Method Summary

Modifier and Type	Method and Description
List<Object>	deserialize(org.apache.qpid.amqp_1_0.client.Message message) Deserialize an AMQP Message into a Tuple.
Fields	getOutputFields() Retrieve the Fields that are present on tuples created by this object.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventDataScheme

public EventDataScheme()

Method Detail

deserialize

public List<Object> deserialize(org.apache.qpid.amqp_1_0.client.Message message)

Description copied from interface: IEventDataScheme

Deserialize an AMQP Message into a Tuple.

Specified by:

deserialize in interface IEventDataScheme

Parameters:

message - The Message to Deserialize.

Returns:

A tuple containing the deserialized fields of the message.

See Also:

for the list of fields the tuple will contain.

getOutputFields

public Fields getOutputFields()

Description copied from interface: IEventDataScheme

Retrieve the Fields that are present on tuples created by this object.

Specified by:

getOutputFields in interface IEventDataScheme

Returns:

The Fields that are present on tuples created by this object.