storm.kafka
Class StringScheme

java.lang.Object
  extended by storm.kafka.StringScheme
All Implemented Interfaces:
Scheme, Serializable
Direct Known Subclasses:
StringKeyValueScheme

public class StringScheme
extends Object
implements Scheme

See Also:
Serialized Form

Field Summary
static String STRING_SCHEME_KEY
           
 
Constructor Summary
StringScheme()
           
 
Method Summary
 List<Object> deserialize(byte[] bytes)
           
static String deserializeString(byte[] string)
           
 Fields getOutputFields()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

STRING_SCHEME_KEY

public static final String STRING_SCHEME_KEY
See Also:
Constant Field Values
Constructor Detail

StringScheme

public StringScheme()
Method Detail

deserialize

public List<Object> deserialize(byte[] bytes)
Specified by:
deserialize in interface Scheme

deserializeString

public static String deserializeString(byte[] string)

getOutputFields

public Fields getOutputFields()
Specified by:
getOutputFields in interface Scheme


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