org.thales.punch.libraries.storm.spout.impl

Class StringKafkaSpoutScheme

java.lang.Object

org.thales.punch.libraries.storm.spout.impl.StringKafkaSpoutScheme

All Implemented Interfaces:

Serializable, org.apache.storm.spout.Scheme

public class StringKafkaSpoutScheme
extends Object
implements org.apache.storm.spout.Scheme

This is what is needed to get the message avalaible under the a given tuple field.

Author:

dimi

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
String	fieldName

Constructor Summary

Constructors

Constructor and Description
StringKafkaSpoutScheme(String fieldName) Associated a field to this scheme so that the spout will emit tuple with the value under that field name.

Method Summary

Modifier and Type	Method and Description
List<Object>	deserialize(byte[] bytes)
List<Object>	deserialize(ByteBuffer bytes)
static String	deserializeString(byte[] string)
org.apache.storm.tuple.Fields	getOutputFields()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

fieldName

public final String fieldName

Constructor Detail

StringKafkaSpoutScheme

public StringKafkaSpoutScheme(String fieldName)

Associated a field to this scheme so that the spout will emit tuple with the value under that field name.

Parameters:

fieldName - the name of the field used in the storm stream.

Method Detail

deserialize

public List<Object> deserialize(byte[] bytes)

deserializeString

public static String deserializeString(byte[] string)

getOutputFields

public org.apache.storm.tuple.Fields getOutputFields()

Specified by:

getOutputFields in interface org.apache.storm.spout.Scheme

toString

public String toString()

Overrides:

toString in class Object

deserialize

public List<Object> deserialize(ByteBuffer bytes)

Specified by:

deserialize in interface org.apache.storm.spout.Scheme