org.apache.storm.kafka

Class KeyValueSchemeAsMultiScheme

java.lang.Object

org.apache.storm.spout.SchemeAsMultiScheme

org.apache.storm.kafka.KeyValueSchemeAsMultiScheme

All Implemented Interfaces:

Serializable, MultiScheme

public class KeyValueSchemeAsMultiScheme
extends SchemeAsMultiScheme

See Also:

Serialized Form

Field Summary

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

scheme

Constructor Summary

Constructors

Constructor and Description
KeyValueSchemeAsMultiScheme(KeyValueScheme scheme)

Method Summary

Modifier and Type	Method and Description
Iterable<List<Object>>	deserializeKeyAndValue(ByteBuffer key, ByteBuffer value)

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

KeyValueSchemeAsMultiScheme

public KeyValueSchemeAsMultiScheme(KeyValueScheme scheme)

Method Detail

deserializeKeyAndValue

public Iterable<List<Object>> deserializeKeyAndValue(ByteBuffer key,
                                                     ByteBuffer value)