storm.kafka
Interface KeyValueScheme

All Superinterfaces:
Scheme, Serializable
All Known Implementing Classes:
StringKeyValueScheme

public interface KeyValueScheme
extends Scheme


Method Summary
 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)


Copyright © 2016 The Apache Software Foundation. All Rights Reserved.