storm.kafka.bolt.mapper
Class FieldNameBasedTupleToKafkaMapper<K,V>

java.lang.Object
  extended by storm.kafka.bolt.mapper.FieldNameBasedTupleToKafkaMapper<K,V>
All Implemented Interfaces:
Serializable, TupleToKafkaMapper

public class FieldNameBasedTupleToKafkaMapper<K,V>
extends Object
implements TupleToKafkaMapper

See Also:
Serialized Form

Field Summary
static String BOLT_KEY
           
static String BOLT_MESSAGE
           
 String boltKeyField
           
 String boltMessageField
           
 
Constructor Summary
FieldNameBasedTupleToKafkaMapper()
           
FieldNameBasedTupleToKafkaMapper(String boltKeyField, String boltMessageField)
           
 
Method Summary
 K getKeyFromTuple(Tuple tuple)
           
 V getMessageFromTuple(Tuple tuple)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

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
Constructor Detail

FieldNameBasedTupleToKafkaMapper

public FieldNameBasedTupleToKafkaMapper()

FieldNameBasedTupleToKafkaMapper

public FieldNameBasedTupleToKafkaMapper(String boltKeyField,
                                        String boltMessageField)
Method Detail

getKeyFromTuple

public K getKeyFromTuple(Tuple tuple)
Specified by:
getKeyFromTuple in interface TupleToKafkaMapper

getMessageFromTuple

public V getMessageFromTuple(Tuple tuple)
Specified by:
getMessageFromTuple in interface TupleToKafkaMapper


Copyright © 2016 The Apache Software Foundation. All Rights Reserved.