org.apache.storm.kafka

Class StringKeyValueScheme

java.lang.Object

org.apache.storm.kafka.StringScheme

org.apache.storm.kafka.StringKeyValueScheme

All Implemented Interfaces:

java.io.Serializable, KeyValueScheme, Scheme

public class StringKeyValueScheme
extends StringScheme
implements KeyValueScheme

See Also:

Serialized Form

Field Summary

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

STRING_SCHEME_KEY

Constructor Summary

Constructors

Constructor and Description
StringKeyValueScheme()

Method Summary

Modifier and Type	Method and Description
java.util.List<java.lang.Object>	deserializeKeyAndValue(byte[] key, byte[] value)

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

deserialize, deserializeString, getOutputFields

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, getOutputFields

Constructor Detail

StringKeyValueScheme

public StringKeyValueScheme()

Method Detail

deserializeKeyAndValue

public java.util.List<java.lang.Object> deserializeKeyAndValue(byte[] key,
                                                               byte[] value)

Specified by:

deserializeKeyAndValue in interface KeyValueScheme