Class KafkaTridentOpaqueSpoutEmitter<K,V>

java.lang.Object
org.apache.storm.kafka.spout.trident.KafkaTridentOpaqueSpoutEmitter<K,V>
All Implemented Interfaces:
Serializable, IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>

public class KafkaTridentOpaqueSpoutEmitter<K,V> extends Object implements IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>, Serializable
See Also: