Uses of Interface
org.apache.storm.trident.spout.IOpaquePartitionedTridentSpout.Emitter

Packages that use IOpaquePartitionedTridentSpout.Emitter

Package	Description
org.apache.storm.eventhubs.trident
org.apache.storm.kafka.spout.trident
org.apache.storm.trident.spout

Uses of IOpaquePartitionedTridentSpout.Emitter in org.apache.storm.eventhubs.trident

Classes in org.apache.storm.eventhubs.trident that implement IOpaquePartitionedTridentSpout.Emitter

Modifier and Type	Class and Description
class	OpaqueTridentEventHubEmitter A thin wrapper of TransactionalTridentEventHubEmitter for OpaqueTridentEventHubSpout.

Methods in org.apache.storm.eventhubs.trident that return IOpaquePartitionedTridentSpout.Emitter

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>	OpaqueTridentEventHubSpout.getEmitter(Map<String,Object> conf, TopologyContext context)

Uses of IOpaquePartitionedTridentSpout.Emitter in org.apache.storm.kafka.spout.trident

Classes in org.apache.storm.kafka.spout.trident that implement IOpaquePartitionedTridentSpout.Emitter

Modifier and Type	Class and Description
class	KafkaTridentOpaqueSpoutEmitter<K,V>

Methods in org.apache.storm.kafka.spout.trident that return IOpaquePartitionedTridentSpout.Emitter

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>	KafkaTridentSpoutOpaque.getEmitter(Map<String,Object> conf, TopologyContext context)

Uses of IOpaquePartitionedTridentSpout.Emitter in org.apache.storm.trident.spout

Methods in org.apache.storm.trident.spout that return IOpaquePartitionedTridentSpout.Emitter

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Emitter<PartitionsT,PartitionT,M>	IOpaquePartitionedTridentSpout.getEmitter(Map<String,Object> conf, TopologyContext context)