Uses of Class
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition
-
Uses of KafkaTridentSpoutTopicPartition in org.apache.storm.kafka.spout.trident
Modifier 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.Modifier and TypeMethodDescriptionvoid
KafkaTridentSpoutEmitter.reEmitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String, Object> currBatch) Emit a batch that has already been emitted.void
KafkaTridentTransactionalSpoutEmitter.reEmitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String, Object> partitionMeta) Modifier 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.void
KafkaTridentOpaqueSpoutEmitter.refreshPartitions
(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities) void
KafkaTridentSpoutEmitter.refreshPartitions
(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities) Prepare the emitter to handle the input partitions.void
KafkaTridentTransactionalSpoutEmitter.refreshPartitions
(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities)