org.apache.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(ByteBuffer key, ByteBuffer value)

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

deserialize, getOutputFields

Method Detail

deserializeKeyAndValue

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