org.apache.storm.kafka

Class MessageMetadataSchemeAsMultiScheme

java.lang.Object

org.apache.storm.spout.SchemeAsMultiScheme

org.apache.storm.kafka.MessageMetadataSchemeAsMultiScheme

All Implemented Interfaces:

java.io.Serializable, MultiScheme

public class MessageMetadataSchemeAsMultiScheme
extends SchemeAsMultiScheme

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.storm.spout.SchemeAsMultiScheme

scheme

Constructor Summary

Constructors

Constructor and Description
MessageMetadataSchemeAsMultiScheme(MessageMetadataScheme scheme)

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<java.util.List<java.lang.Object>>	deserializeMessageWithMetadata(byte[] message, Partition partition, long offset)

Methods inherited from class org.apache.storm.spout.SchemeAsMultiScheme

deserialize, getOutputFields

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageMetadataSchemeAsMultiScheme

public MessageMetadataSchemeAsMultiScheme(MessageMetadataScheme scheme)

Method Detail

deserializeMessageWithMetadata

public java.lang.Iterable<java.util.List<java.lang.Object>> deserializeMessageWithMetadata(byte[] message,
                                                                                           Partition partition,
                                                                                           long offset)