org.apache.storm.eventhubs.spout

Interface IEventDataScheme

All Superinterfaces:

Serializable

All Known Implementing Classes:

BinaryEventDataScheme, EventDataScheme, StringEventDataScheme

public interface IEventDataScheme
extends Serializable

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.

Method Detail

deserialize

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

Deserialize an AMQP Message into a Tuple.

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

Fields getOutputFields()

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

Returns:

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