org.apache.storm.kafka

Class StringMultiSchemeWithTopic

java.lang.Object

org.apache.storm.kafka.StringMultiSchemeWithTopic

All Implemented Interfaces:

Serializable, MultiScheme

public class StringMultiSchemeWithTopic
extends Object
implements MultiScheme

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	STRING_SCHEME_KEY
static String	TOPIC_KEY

Constructor Summary

Constructors

Constructor and Description
StringMultiSchemeWithTopic()

Method Summary

Modifier and Type	Method and Description
Iterable<List<Object>>	deserialize(ByteBuffer bytes)
Iterable<List<Object>>	deserializeWithTopic(String topic, ByteBuffer bytes)
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

TOPIC_KEY

public static final String TOPIC_KEY

See Also:

Constant Field Values

Constructor Detail

StringMultiSchemeWithTopic

public StringMultiSchemeWithTopic()

Method Detail

deserialize

public Iterable<List<Object>> deserialize(ByteBuffer bytes)

Specified by:

deserialize in interface MultiScheme

deserializeWithTopic

public Iterable<List<Object>> deserializeWithTopic(String topic,
                                                   ByteBuffer bytes)

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface MultiScheme