| brokerToNamespaceToBundleRange.get(broker).computeIfAbsent(namespaceName,k -> new HashSet<>()).add(bundleRange); | brokerToNamespaceToBundleRange.get(broker.get()).computeIfAbsent(namespaceName,k -> new HashSet<>()).add(bundleRange); | brokerToNamespaceToBundleRange.get(broker) | brokerToNamespaceToBundleRange.get(broker.get()) | pulsar | d6d4fa3a1103f650bf16e74429f82db3d33fe739 | org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl | | | | TCIVar | broker |
|---|
| v0 | brokerToNamespaceToBundleRange |
|---|
| | | TCIVar | broker |
|---|
| v0 | brokerToNamespaceToBundleRange |
|---|
| Uses | True |
| loadData.getBrokerData().get(broker).getPreallocatedBundleData().put(bundle,data); | loadData.getBrokerData().get(broker.get()).getPreallocatedBundleData().put(bundle,data); | loadData.getBrokerData().get(broker) | loadData.getBrokerData().get(broker.get()) | pulsar | d6d4fa3a1103f650bf16e74429f82db3d33fe739 | org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl | | | | TCIVar | broker |
|---|
| v0 | loadData.getBrokerData() |
|---|
| | | TCIVar | broker |
|---|
| v0 | loadData.getBrokerData() |
|---|
| Uses | True |
| final double maxUsage=loadData.getBrokerData().get(broker).getLocalData().getMaxResourceUsage(); | final double maxUsage=loadData.getBrokerData().get(broker.get()).getLocalData().getMaxResourceUsage(); | loadData.getBrokerData().get(broker) | loadData.getBrokerData().get(broker.get()) | pulsar | d6d4fa3a1103f650bf16e74429f82db3d33fe739 | org.apache.pulsar.broker.loadbalance.impl.ModularLoadManagerImpl | | | | TCIVar | broker |
|---|
| v0 | loadData.getBrokerData() |
|---|
| | | TCIVar | broker |
|---|
| v0 | loadData.getBrokerData() |
|---|
| Uses | True |