org.apache.storm.kafka

Class StringMultiSchemeWithTopic

java.lang.Object

org.apache.storm.kafka.StringMultiSchemeWithTopic

All Implemented Interfaces:

java.io.Serializable, MultiScheme

public class StringMultiSchemeWithTopic
extends java.lang.Object
implements MultiScheme

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	STRING_SCHEME_KEY
static java.lang.String	TOPIC_KEY

Constructor Summary

Constructors

Constructor and Description
StringMultiSchemeWithTopic()

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<java.util.List<java.lang.Object>>	deserialize(java.nio.ByteBuffer bytes)
java.lang.Iterable<java.util.List<java.lang.Object>>	deserializeWithTopic(java.lang.String topic, byte[] 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 java.lang.String STRING_SCHEME_KEY

See Also:

Constant Field Values

TOPIC_KEY

public static final java.lang.String TOPIC_KEY

See Also:

Constant Field Values

Constructor Detail

StringMultiSchemeWithTopic

public StringMultiSchemeWithTopic()

Method Detail

deserialize

public java.lang.Iterable<java.util.List<java.lang.Object>> deserialize(java.nio.ByteBuffer bytes)

Specified by:

deserialize in interface MultiScheme

deserializeWithTopic

public java.lang.Iterable<java.util.List<java.lang.Object>> deserializeWithTopic(java.lang.String topic,
                                                                                 byte[] bytes)

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface MultiScheme