Package org.apache.helix.api.config

Examples of org.apache.helix.api.config.ClusterConfig

219
220
221
222
223
224
225
226
227
228
229
    private Map<String, Map<String, String>> getMapping(final Map<String, List<String>> listResult) {
      final Map<String, Map<String, String>> mapResult = new HashMap<String, Map<String, String>>();
      for (String partition : _partitions) {
        Map<String, String> rawCurStateMap = _currentMapping.get(partition);
        ClusterConfig cluster =
            new ClusterConfig.Builder(ClusterId.from("cluster")).addStateModelDefinition(
                _stateModelDef).build();
        Set<ParticipantId> liveParticipantSet = Sets.newHashSet();
        for (String node : _liveNodes) {
          liveParticipantSet.add(ParticipantId.from(node));
View Full Code Here
228
229
230
231
232
233
234
235
236
237
238
      for (State state : _stateModelDef.getTypedStatesPriorityList()) {
        clusterConfigBuilder.addStateUpperBoundConstraint(Scope.cluster(clusterId),
            _stateModelDef.getStateModelDefId(), state,
            _stateModelDef.getNumParticipantsPerState(state));
      }
      ClusterConfig clusterConfig = clusterConfigBuilder.build();
      for (String partition : _partitions) {
        PartitionId partitionId = PartitionId.from(partition);
        Set<ParticipantId> disabledParticipantsForPartition = Collections.emptySet();
        Set<PartitionId> disabledPartitionIdSet = Collections.emptySet();
        Set<String> tags = Collections.emptySet();
View Full Code Here
TOP

Related Classes of org.apache.helix.api.config.ClusterConfig

  • org.apache.helix.api.accessor.ClusterAccessor
  • org.apache.helix.api.accessor.TestAccessorRecreate
  • org.apache.helix.api.accessor.TestAtomicAccessors
  • org.apache.helix.api.TestUpdateConfig
  • org.apache.helix.controller.strategy.TestAutoRebalanceStrategy$AutoRebalanceTester
  • org.apache.helix.controller.strategy.TestNewAutoRebalanceStrategy$AutoRebalanceTester
  • org.apache.helix.examples.LogicalModelExample
  • org.apache.helix.model.Alerts
  • org.apache.helix.model.builder.ConstraintItemBuilder
  • org.apache.helix.model.ClusterConfiguration
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.