本文整理了Java中org.apache.helix.controller.rebalancer.constraint.dataprovider.ZkBasedPartitionWeightProvider.<init>()方法的一些代码示例，展示了ZkBasedPartitionWeightProvider.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkBasedPartitionWeightProvider.<init>()方法的具体详情如下：
包路径：org.apache.helix.controller.rebalancer.constraint.dataprovider.ZkBasedPartitionWeightProvider
类名称：ZkBasedPartitionWeightProvider
方法名：<init>

ZkBasedPartitionWeightProvider.<init>介绍

暂无

代码示例

代码示例来源：origin: org.apache.helix/helix-core

new ZkBasedPartitionWeightProvider(ZK_ADDRESS, CLUSTER_NAME, "QPS");
  new ZkBasedPartitionWeightProvider(ZK_ADDRESS, CLUSTER_NAME, "MEM");
  new ZkBasedPartitionWeightProvider(ZK_ADDRESS, CLUSTER_NAME, "QPS");
qpsCapacityProvider =
  new ZkBasedCapacityProvider(ZK_ADDRESS, CLUSTER_NAME, "QPS");
memoryWeightProvider =
  new ZkBasedPartitionWeightProvider(ZK_ADDRESS, CLUSTER_NAME, "MEM");
memoryCapacityProvider =
  new ZkBasedCapacityProvider(ZK_ADDRESS, CLUSTER_NAME, "MEM");

代码示例来源：origin: apache/helix

new ZkBasedPartitionWeightProvider(ZK_ADDRESS, CLUSTER_NAME, "QPS");
  new ZkBasedPartitionWeightProvider(ZK_ADDRESS, CLUSTER_NAME, "MEM");
  new ZkBasedPartitionWeightProvider(ZK_ADDRESS, CLUSTER_NAME, "QPS");
qpsCapacityProvider =
  new ZkBasedCapacityProvider(ZK_ADDRESS, CLUSTER_NAME, "QPS");
memoryWeightProvider =
  new ZkBasedPartitionWeightProvider(ZK_ADDRESS, CLUSTER_NAME, "MEM");
memoryCapacityProvider =
  new ZkBasedCapacityProvider(ZK_ADDRESS, CLUSTER_NAME, "MEM");

代码示例来源：origin: apache/helix

new ZkBasedPartitionWeightProvider(ZK_ADDR, CLUSTER_NAME, "QPS");
weightProvider.updateWeights(Collections.EMPTY_MAP, Collections.EMPTY_MAP, resourceWeight);

代码示例来源：origin: apache/helix

@Test
public void testRebalanceUsingZkDataProvider() {
 // capacity / weight
 Map<String, Integer> capacity = new HashMap<>();
 for (String instance : instanceNames) {
  capacity.put(instance, defaultCapacity);
 }
 ZkBasedPartitionWeightProvider weightProvider =
   new ZkBasedPartitionWeightProvider(ZK_ADDR, CLUSTER_NAME, "QPS");
 weightProvider.updateWeights(Collections.EMPTY_MAP, Collections.EMPTY_MAP, resourceWeight);
 ZkBasedCapacityProvider capacityProvider =
   new ZkBasedCapacityProvider(ZK_ADDR, CLUSTER_NAME, "QPS");
 capacityProvider.updateCapacity(capacity, Collections.EMPTY_MAP, 0);
 TotalCapacityConstraint capacityConstraint =
   new TotalCapacityConstraint(weightProvider, capacityProvider);
 PartitionWeightAwareEvennessConstraint evenConstraint =
   new PartitionWeightAwareEvennessConstraint(weightProvider, capacityProvider);
 WeightAwareRebalanceUtil util = new WeightAwareRebalanceUtil(clusterConfig, instanceConfigs);
 ResourcesStateMap assignment = util.buildIncrementalRebalanceAssignment(resourceConfigs, null,
   Collections.<AbstractRebalanceHardConstraint>singletonList(capacityConstraint),
   Collections.<AbstractRebalanceSoftConstraint>singletonList(evenConstraint));
 Map<String, Integer> weightCount = checkPartitionUsage(assignment, weightProvider);
 int max = Collections.max(weightCount.values());
 int min = Collections.min(weightCount.values());
 // Since the accuracy of Default evenness constraint is 0.01, diff should be 1/100 of participant capacity in max.
 Assert.assertTrue((max - min) <= defaultCapacity / 100);
}

代码示例来源：origin: apache/helix

new ZkBasedPartitionWeightProvider(ZK_ADDR, CLUSTER_NAME, "Test");
weightProvider.updateWeights(resourceDefaultWeightMap, partitionWeightMap, resourceWeight);
weightProvider = new ZkBasedPartitionWeightProvider(ZK_ADDR, CLUSTER_NAME, "Test");
validateWeight(weightProvider);
weightProvider = new ZkBasedPartitionWeightProvider(ZK_ADDR, CLUSTER_NAME, "Fack");
for (String resource : resourceNames) {
 for (String partition : partitions) {

代码示例来源：origin: apache/helix

new ZkBasedPartitionWeightProvider(ZK_ADDR, CLUSTER_NAME, "QPS");
weightProvider.updateWeights(Collections.EMPTY_MAP, Collections.EMPTY_MAP, resourceWeight);

代码示例来源：origin: apache/helix

new ZkBasedPartitionWeightProvider(ZK_ADDR, CLUSTER_NAME, "QPS");
weightProvider.updateWeights(Collections.EMPTY_MAP, Collections.EMPTY_MAP, resourceWeight);