Package | Description |
---|---|
org.apache.storm.kafka.spout.trident |
Modifier and Type | Method and Description |
---|---|
IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>> |
KafkaTridentSpoutOpaque.getEmitter(Map conf,
TopologyContext context) |
List<KafkaTridentSpoutTopicPartition> |
KafkaTridentSpoutEmitter.getOrderedPartitions(List<Map<String,Object>> allPartitionInfo)
Computes ordered list of topic-partitions for this task taking into consideration that topic-partitions for this task must be assigned to the Kafka consumer running on this task.
|
List<KafkaTridentSpoutTopicPartition> |
KafkaTridentSpoutEmitter.getPartitionsForTask(int taskId,
int numTasks,
List<KafkaTridentSpoutTopicPartition> allPartitionInfo) |
Modifier and Type | Method and Description |
---|---|
Map<String,Object> |
KafkaTridentSpoutEmitter.emitPartitionBatch(TransactionAttempt tx,
TridentCollector collector,
KafkaTridentSpoutTopicPartition currBatchPartition,
Map<String,Object> lastBatch) |
Modifier and Type | Method and Description |
---|---|
List<KafkaTridentSpoutTopicPartition> |
KafkaTridentSpoutEmitter.getPartitionsForTask(int taskId,
int numTasks,
List<KafkaTridentSpoutTopicPartition> allPartitionInfo) |
void |
KafkaTridentSpoutEmitter.refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.