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 conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<Partitions,Partition,Map>	TransactionalTridentEventHubSpout.getEmitter(Map conf, TopologyContext context)
List<Partition>	TransactionalTridentEventHubEmitter.getOrderedPartitions(Partitions partitions)
List<Partition>	OpaqueTridentEventHubEmitter.getOrderedPartitions(Partitions partitions)
List<Partition>	Partitions.getPartitions()
List<Partition>	OpaqueTridentEventHubEmitter.getPartitionsForTask(int taskId, int numTasks, List<Partition> allPartitionInfoSorted)

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

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

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

Modifier and Type	Method and Description
List<Partition>	OpaqueTridentEventHubEmitter.getPartitionsForTask(int taskId, int numTasks, List<Partition> allPartitionInfoSorted)
void	TransactionalTridentEventHubEmitter.refreshPartitions(List<Partition> partitionList)
void	OpaqueTridentEventHubEmitter.refreshPartitions(List<Partition> partitionList)