org.apache.storm.rocketmq.spout.scheme

Class StringScheme

java.lang.Object

org.apache.storm.rocketmq.spout.scheme.StringScheme

All Implemented Interfaces:

Serializable, Scheme

Direct Known Subclasses:

StringKeyValueScheme

public class StringScheme
extends Object
implements Scheme

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	STRING_SCHEME_KEY

Constructor Summary

Constructors

Constructor and Description
StringScheme()

Method Summary

Modifier and Type	Method and Description
List<Object>	deserialize(ByteBuffer bytes)
static String	deserializeString(ByteBuffer byteBuffer) Deserialize ByteBuffer to 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(ByteBuffer bytes)

Specified by:

deserialize in interface Scheme

deserializeString

public static String deserializeString(ByteBuffer byteBuffer)

Deserialize ByteBuffer to String.

Parameters:

byteBuffer - input ByteBuffer

Returns:

deserialized string

getOutputFields

public Fields getOutputFields()

Specified by:

getOutputFields in interface Scheme