storm.kafka.bolt.mapper
Interface TupleToKafkaMapper<K,V>
- Type Parameters:
K
- type of key.V
- type of value.
- All Superinterfaces:
- Serializable
- All Known Implementing Classes:
- FieldNameBasedTupleToKafkaMapper
public interface TupleToKafkaMapper<K,V>
- extends Serializable
as the really verbose name suggests this interface mapps a storm tuple to kafka key and message.
getKeyFromTuple
K getKeyFromTuple(Tuple tuple)
getMessageFromTuple
V getMessageFromTuple(Tuple tuple)
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.