storm.kafka

Class StringKeyValueScheme

java.lang.Object

storm.kafka.StringScheme

storm.kafka.StringKeyValueScheme

All Implemented Interfaces:

Scheme, Serializable, KeyValueScheme

public class StringKeyValueScheme
extends StringScheme
implements KeyValueScheme

See Also:

Serialized Form

Field Summary

Fields inherited from class storm.kafka.StringScheme

STRING_SCHEME_KEY

Constructor Summary

Constructors

Constructor and Description
StringKeyValueScheme()

Method Summary

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

Methods inherited from class 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 backtype.storm.spout.Scheme

deserialize, getOutputFields

Constructor Detail

StringKeyValueScheme

public StringKeyValueScheme()

Method Detail

deserializeKeyAndValue

public List<Object> deserializeKeyAndValue(byte[] key,
                                           byte[] value)

Specified by:

deserializeKeyAndValue in interface KeyValueScheme