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:
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionFieldNameBasedTupleToKafkaMapper(String boltKeyField, String boltMessageField) 
- 
Method Summary
- 
Field Details- 
BOLT_KEY- See Also:
 
- 
BOLT_MESSAGE- See Also:
 
- 
boltKeyField
- 
boltMessageField
 
- 
- 
Constructor Details- 
FieldNameBasedTupleToKafkaMapperpublic FieldNameBasedTupleToKafkaMapper()
- 
FieldNameBasedTupleToKafkaMapper
 
- 
- 
Method Details- 
getKeyFromTuple- Specified by:
- getKeyFromTuplein interface- TupleToKafkaMapper<K,- V> 
 
- 
getMessageFromTuple- Specified by:
- getMessageFromTuplein interface- TupleToKafkaMapper<K,- V> 
 
 
-