org.apache.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

Interface defining a mapping from storm tuple to kafka key and message.

Method Summary

Modifier and Type	Method and Description
K	getKeyFromTuple(Tuple tuple)
V	getMessageFromTuple(Tuple tuple)

Method Detail

getKeyFromTuple

K getKeyFromTuple(Tuple tuple)

getMessageFromTuple

V getMessageFromTuple(Tuple tuple)