Class FieldNameBasedTupleToKafkaMapper<K,V>
- java.lang.Object
-
- org.apache.storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper<K,V>
-
- All Implemented Interfaces:
Serializable,TupleToKafkaMapper<K,V>
public class FieldNameBasedTupleToKafkaMapper<K,V> extends Object implements TupleToKafkaMapper<K,V>
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static StringBOLT_KEYstatic StringBOLT_MESSAGEStringboltKeyFieldStringboltMessageField
-
Constructor Summary
Constructors Constructor Description FieldNameBasedTupleToKafkaMapper()FieldNameBasedTupleToKafkaMapper(String boltKeyField, String boltMessageField)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description KgetKeyFromTuple(Tuple tuple)VgetMessageFromTuple(Tuple tuple)
-
-
-
Field Detail
-
BOLT_KEY
public static final String BOLT_KEY
- See Also:
- Constant Field Values
-
BOLT_MESSAGE
public static final String BOLT_MESSAGE
- See Also:
- Constant Field Values
-
boltKeyField
public String boltKeyField
-
boltMessageField
public String boltMessageField
-
-
Method Detail
-
getKeyFromTuple
public K getKeyFromTuple(Tuple tuple)
- Specified by:
getKeyFromTuplein interfaceTupleToKafkaMapper<K,V>
-
getMessageFromTuple
public V getMessageFromTuple(Tuple tuple)
- Specified by:
getMessageFromTuplein interfaceTupleToKafkaMapper<K,V>
-
-