storm.kafka

Interface KeyValueScheme

All Superinterfaces:

Scheme, Serializable

All Known Implementing Classes:

StringKeyValueScheme

public interface KeyValueScheme
extends Scheme

Method Summary

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

Methods inherited from interface backtype.storm.spout.Scheme

deserialize, getOutputFields

Method Detail

deserializeKeyAndValue

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