Package org.apache.storm.kafka.trident.mapper

Interface TridentTupleToKafkaMapper<K,V>

All Superinterfaces:

Serializable

All Known Implementing Classes:

FieldNameBasedTupleToKafkaMapper

public interface TridentTupleToKafkaMapper<K,V>
extends Serializable

Method Summary

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

Method Details

getKeyFromTuple

K getKeyFromTuple(TridentTuple tuple)

getMessageFromTuple

V getMessageFromTuple(TridentTuple tuple)