Uses of Class
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition
Packages that use KafkaTridentSpoutTopicPartition
-
Uses of KafkaTridentSpoutTopicPartition in org.apache.storm.kafka.spout.trident
Methods in org.apache.storm.kafka.spout.trident that return types with arguments of type KafkaTridentSpoutTopicPartitionModifier and TypeMethodDescriptionKafkaTridentOpaqueSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastBatchMetaMap) KafkaTridentSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastBatchMetaMap) Emit a new batch.KafkaTridentTransactionalSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastPartitionMetaMap) IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>, KafkaTridentSpoutTopicPartition, Map<String, Object>> KafkaTridentSpoutOpaque.getEmitter(Map<String, Object> conf, TopologyContext context) IPartitionedTridentSpout.Emitter<List<Map<String,Object>>, KafkaTridentSpoutTopicPartition, Map<String, Object>> KafkaTridentSpoutTransactional.getEmitter(Map<String, Object> conf, TopologyContext context) KafkaTridentOpaqueSpoutEmitter.getOrderedPartitions(List<Map<String, Object>> allPartitionInfo) KafkaTridentSpoutEmitter.getOrderedPartitions(List<Map<String, Object>> allPartitionInfo) Get the input partitions in sorted order.KafkaTridentTransactionalSpoutEmitter.getOrderedPartitions(List<Map<String, Object>> allPartitionInfo) KafkaTridentOpaqueSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted) KafkaTridentSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted) Get the partitions that should be handled by this task.Methods in org.apache.storm.kafka.spout.trident with parameters of type KafkaTridentSpoutTopicPartitionModifier and TypeMethodDescriptionvoidKafkaTridentSpoutEmitter.reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String, Object> currBatch) Emit a batch that has already been emitted.voidKafkaTridentTransactionalSpoutEmitter.reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String, Object> partitionMeta) Method parameters in org.apache.storm.kafka.spout.trident with type arguments of type KafkaTridentSpoutTopicPartitionModifier and TypeMethodDescriptionKafkaTridentOpaqueSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastBatchMetaMap) KafkaTridentOpaqueSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastBatchMetaMap) KafkaTridentSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastBatchMetaMap) Emit a new batch.KafkaTridentSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastBatchMetaMap) Emit a new batch.KafkaTridentTransactionalSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastPartitionMetaMap) KafkaTridentTransactionalSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastPartitionMetaMap) KafkaTridentOpaqueSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted) KafkaTridentSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted) Get the partitions that should be handled by this task.voidKafkaTridentOpaqueSpoutEmitter.refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities) voidKafkaTridentSpoutEmitter.refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities) Prepare the emitter to handle the input partitions.voidKafkaTridentTransactionalSpoutEmitter.refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities)