org.apache.storm.kafka

Interface KeyValueScheme

All Superinterfaces:

Scheme, java.io.Serializable

All Known Implementing Classes:

StringKeyValueScheme

public interface KeyValueScheme
extends Scheme

Method Summary

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

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

deserialize, getOutputFields

Method Detail

deserializeKeyAndValue

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