Uses of Class
org.apache.storm.eventhubs.trident.Partition

Packages that use Partition

Package	Description
org.apache.storm.eventhubs.trident

Uses of Partition in org.apache.storm.eventhubs.trident

Methods in org.apache.storm.eventhubs.trident that return types with arguments of type Partition

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Emitter<Partitions,Partition,Map>	OpaqueTridentEventHubSpout.getEmitter(Map<String,Object> conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<Partitions,Partition,Map<String,Object>>	TransactionalTridentEventHubSpout.getEmitter(Map<String,Object> conf, TopologyContext context)
List<Partition>	TransactionalTridentEventHubEmitter.getOrderedPartitions(Partitions partitions)
List<Partition>	OpaqueTridentEventHubEmitter.getOrderedPartitions(Partitions partitions)
List<Partition>	Partitions.getPartitions()

Methods in org.apache.storm.eventhubs.trident with parameters of type Partition

Modifier and Type	Method and Description
void	Partitions.addPartition(Partition partition)
Map	OpaqueTridentEventHubEmitter.emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map meta)
void	TransactionalTridentEventHubEmitter.emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map<String,Object> meta)
Map<String,Object>	TransactionalTridentEventHubEmitter.emitPartitionBatchNew(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map<String,Object> meta)

Method parameters in org.apache.storm.eventhubs.trident with type arguments of type Partition

Modifier and Type	Method and Description
void	TransactionalTridentEventHubEmitter.refreshPartitions(List<Partition> partitionList)
void	OpaqueTridentEventHubEmitter.refreshPartitions(List<Partition> partitionList)