Examples of org.apache.helix.api.accessor.ClusterAccessor.addResource()

Class org.apache.helix.api.accessor.ClusterAccessor

Examples of org.apache.helix.api.accessor.ClusterAccessor.addResource()

org.apache.helix.api.accessor.ClusterAccessor.addResource()
add a resource to cluster @param resource @return true if resource added, false if there was an error

    idealStateBuilder.setNumReplica(1).setStateModelDefId(stateModelDefId);
    idealStateBuilder.assignPreferenceList(partition0, participantId);
    IdealState idealState = idealStateBuilder.build();
    clusterAccessor.createCluster(new ClusterConfig.Builder(clusterId).addStateModelDefinition(
        stateModelDef).build());
    clusterAccessor.addResource(new ResourceConfig.Builder(resourceId).idealState(idealState)
        .build());
    clusterAccessor.addParticipant(new ParticipantConfig.Builder(participantId).build());


    // start controller
    HelixController controller = connection.createController(clusterId, controllerId);

View Full Code Here

          new ResourceConfig.Builder(ResourceId.from(resourceName));
      ResourceConfig resourceConfig =
          resourceConfigBuilder.provisionerConfig(provisionerConfig)
              .idealState(idealStateBuilder.build()) //
              .build();
      clusterAccessor.addResource(resourceConfig);
    }
    // start controller
    ControllerId controllerId = ControllerId.from("controller1");
    HelixController controller = connection.createController(clusterId, controllerId);
    controller.start();

View Full Code Here

    for (int i = 0; i < NUM_PARTITIONS; i++) {
      idealStateBuilder.add(PartitionId.from(resourceId, String.valueOf(i)));
    }
    idealStateBuilder.setNumReplica(NUM_REPLICAS).setStateModelDefId(
        masterSlave.getStateModelDefId());
    clusterAccessor.addResource(new ResourceConfig.Builder(ResourceId.from(resourceName))
        .provisionerConfig(provisionerConfig).idealState(idealStateBuilder.build()).build());


    // start controller
    ControllerId controllerId = ControllerId.from("controller1");
    HelixController controller = connection.createController(clusterId, controllerId);

View Full Code Here

TOP

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.