org.apache.storm.kafka

Class StringMessageAndMetadataScheme

java.lang.Object

org.apache.storm.kafka.StringScheme

org.apache.storm.kafka.StringMessageAndMetadataScheme

All Implemented Interfaces:

Serializable, MessageMetadataScheme, Scheme

public class StringMessageAndMetadataScheme
extends StringScheme
implements MessageMetadataScheme

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	STRING_SCHEME_OFFSET
static String	STRING_SCHEME_PARTITION_KEY

Fields inherited from class org.apache.storm.kafka.StringScheme

STRING_SCHEME_KEY

Constructor Summary

Constructors

Constructor and Description
StringMessageAndMetadataScheme()

Method Summary

Modifier and Type	Method and Description
List<Object>	deserializeMessageWithMetadata(ByteBuffer message, Partition partition, long offset)
Fields	getOutputFields()

Methods inherited from class org.apache.storm.kafka.StringScheme

deserialize, deserializeString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.storm.spout.Scheme

deserialize

Field Detail

STRING_SCHEME_PARTITION_KEY

public static final String STRING_SCHEME_PARTITION_KEY

See Also:

Constant Field Values

STRING_SCHEME_OFFSET

public static final String STRING_SCHEME_OFFSET

See Also:

Constant Field Values

Constructor Detail

StringMessageAndMetadataScheme

public StringMessageAndMetadataScheme()

Method Detail

deserializeMessageWithMetadata

public List<Object> deserializeMessageWithMetadata(ByteBuffer message,
                                                   Partition partition,
                                                   long offset)

Specified by:

deserializeMessageWithMetadata in interface MessageMetadataScheme

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface Scheme

Overrides:

getOutputFields in class StringScheme