Class KafkaTridentSpoutOpaque<K,V>

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

public class KafkaTridentSpoutOpaque<K,V> extends Object implements IOpaquePartitionedTridentSpout<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>
See Also: