Class KafkaTridentSpoutTransactional<K,V>

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

public class KafkaTridentSpoutTransactional<K,V> extends Object implements IPartitionedTridentSpout<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>, Serializable
See Also: