Package | Description |
---|---|
storm.kafka | |
storm.kafka.trident |
Modifier and Type | Method and Description |
---|---|
GlobalPartitionInformation |
DynamicBrokersReader.getBrokerInfo()
Get all partitions with their current leaders
|
GlobalPartitionInformation |
StaticHosts.getPartitionInformation() |
Modifier and Type | Method and Description |
---|---|
static List<Partition> |
KafkaUtils.calculatePartitionsForTask(GlobalPartitionInformation partitionInformation,
int totalTasks,
int taskIndex) |
Constructor and Description |
---|
StaticHosts(GlobalPartitionInformation partitionInformation) |
Modifier and Type | Method and Description |
---|---|
GlobalPartitionInformation |
ZkBrokerReader.getCurrentBrokers() |
GlobalPartitionInformation |
StaticBrokerReader.getCurrentBrokers() |
GlobalPartitionInformation |
IBrokerReader.getCurrentBrokers() |
Modifier and Type | Method and Description |
---|---|
IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> |
TridentKafkaEmitter.asOpaqueEmitter() |
IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> |
OpaqueTridentKafkaSpout.getEmitter(Map conf,
TopologyContext context) |
Constructor and Description |
---|
StaticBrokerReader(GlobalPartitionInformation partitionInformation) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.