List of addInstance() Examples

Examples of addInstance()

com.alu.e3.topology.model.Topology.addInstance()
com.espertech.esper.epl.named.NamedWindowProcessor.addInstance()
com.linkedin.helix.HelixAdmin.addInstance()
Add an instance to a cluster @param clusterName @param instanceConfig
com.linkedin.helix.manager.zk.ZKHelixAdmin.addInstance()
com.netflix.discovery.shared.Application.addInstance()
Add the given instance info the list. @param i the instance info object to be added.
com.netflix.simianarmy.basic.chaos.BasicInstanceGroup.addInstance()
{@inheritDoc}
com.sun.xml.ws.security.SecurityContextTokenInfo.addInstance()
com.sun.xml.ws.security.secconv.impl.SecurityContextTokenInfoImpl.addInstance()
jsprit.analysis.toolbox.ComputationalLaboratory.addInstance()
Adds instance by name. @param name @param problem @throws IllegalStateException if there is already an instance with the same name.
org.apache.clerezza.triaxrs.providers.CascadingProviders.addInstance()
org.apache.ctakes.temporal.utils.SMOTEplus.addInstance()
org.apache.helix.HelixAdmin.addInstance()
Add an instance to a cluster @param clusterName @param instanceConfig
org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()
org.apache.mahout.classifier.ConfusionMatrix.addInstance()
org.apache.mahout.classifier.ResultAnalyzer.addInstance()
@param correctLabel The correct label @param classifiedResult The classified result @return whether the instance was correct or not
org.apache.tapestry5.ioc.Configuration.addInstance()
Automatically instantiates an instance of the class, with dependencies injected, and adds it to the configuration. When the configuration type is an interface and the class to be contributed is a local file, then a reloadable proxy for the class will be created and contributed. @param clazz what class to instantiate @since 5.1.0.0
org.dcm4che3.tool.mkkos.MkKOS.addInstance()
org.dspace.app.xmlui.wing.element.Composite.addInstance()
Add a field instance @return instance
org.dspace.app.xmlui.wing.element.Select.addInstance()
Add a field instance @return instance
org.dspace.app.xmlui.wing.element.Text.addInstance()
Add a field instance @return instance
org.dspace.app.xmlui.wing.element.TextArea.addInstance()
Add a field instance @return instance
org.metaworks.GridApplication.addInstance()
org.photovault.imginfo.PhotoInfo.addInstance()
Adds a new image instance for this photo @param i The new instance
org.testng.IClass.addInstance()
unbbayes.prs.mebn.entity.ObjectEntity.addInstance()

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()

      String instance = "localhost_" + instances[i];
      InstanceConfig instanceConfig = new InstanceConfig(instance);
      instanceConfig.setHostName("localhost");
      instanceConfig.setPort("" + instances[i]);
      instanceConfig.setInstanceEnabled(true);
      admin.addInstance(clusterName, instanceConfig);
    }
  }


  protected void runPipeline(ClusterEvent event, Pipeline pipeline)
  {

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()

      int port = 12918 + i;
      InstanceConfig config = new InstanceConfig("localhost_" + port);
      config.setHostName("localhost");
      config.setPort(Integer.toString(port));
      config.setInstanceEnabled(true);
      admin.addInstance(clusterName, config);
    }


    // add resource "TestDB" which has 4 partitions and uses MasterSlave state model
    String resourceName = "TestDB";
    if (idealStateMode == IdealStateModeProperty.AUTO

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()

      if (!nodes.contains("consumer_" + consumerId))
      {
        InstanceConfig config = new InstanceConfig("consumer_" + consumerId);
        config.setHostName("localhost");
        config.setInstanceEnabled(true);
        admin.addInstance(clusterName, config);
      }


      // start consumer
      final Consumer consumer =
          new Consumer(zkAddr, clusterName, "consumer_" + consumerId, mqServer);

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()

    if (instancesInCluster == null || !instancesInCluster.contains(instanceName))
    {
      InstanceConfig config = new InstanceConfig(instanceName);
      config.setHostName("localhost");
      config.setPort("12000");
      helixAdmin.addInstance(clusterName, config);
    }
  }


  public void stop()
  {

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()

      String instance = "localhost_" + instances[i];
      InstanceConfig instanceConfig = new InstanceConfig(instance);
      instanceConfig.setHostName("localhost");
      instanceConfig.setPort("" + instances[i]);
      instanceConfig.setInstanceEnabled(true);
      admin.addInstance(clusterName, instanceConfig);
    }
  }


  protected void runPipeline(ClusterEvent event, Pipeline pipeline) {
    try {

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()


    // test ZkDataAccessor
    ZKHelixAdmin admin = new ZKHelixAdmin(zkClient);
    admin.addCluster(className, true);
    InstanceConfig instanceConfig = new InstanceConfig("localhost_12918");
    admin.addInstance(className, instanceConfig);


    // oversized data should not create any new data on zk
    ZKHelixDataAccessor accessor =
        new ZKHelixDataAccessor(className, new ZkBaseDataAccessor(zkClient));
    Builder keyBuilder = accessor.keyBuilder();

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()


    // test ZkDataAccessor
    ZKHelixAdmin admin = new ZKHelixAdmin(zkClient);
    admin.addCluster(className, true);
    InstanceConfig instanceConfig = new InstanceConfig("localhost_12918");
    admin.addInstance(className, instanceConfig);


    // oversized data should not create any new data on zk
    ZKHelixDataAccessor accessor =
        new ZKHelixDataAccessor(className, new ZkBaseDataAccessor(zkClient));
    Builder keyBuilder = accessor.keyBuilder();

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()

      List<String> nodes = admin.getInstancesInCluster(clusterName);
      if (!nodes.contains("consumer_" + consumerId)) {
        InstanceConfig config = new InstanceConfig("consumer_" + consumerId);
        config.setHostName("localhost");
        config.setInstanceEnabled(true);
        admin.addInstance(clusterName, config);
      }


      // start consumer
      final Consumer consumer =
          new Consumer(zkAddr, clusterName, "consumer_" + consumerId, mqServer);

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()

        String serverId = "localhost_" + port;
        InstanceConfig config = new InstanceConfig(serverId);
        config.setHostName("localhost");
        config.setPort(port);
        config.setInstanceEnabled(true);
        admin.addInstance(clusterName, config);
      }
      // add resource "repository" which has 1 partition
      String resourceName = DEFAULT_RESOURCE_NAME;
      admin.addResource(clusterName, resourceName, DEFAULT_PARTITION_NUMBER, DEFAULT_STATE_MODEL,
          RebalanceMode.SEMI_AUTO.toString());

View Full Code Here

Examples of org.apache.helix.manager.zk.ZKHelixAdmin.addInstance()

      Assert
          .fail("Except fail to set participant-config because participant: localhost_12918 is not added to cluster yet");
    } catch (HelixException e) {
      // OK
    }
    admin.addInstance(clusterName, new InstanceConfig("localhost_12918"));


    try {
      configAccessor.set(participantScope, "participantConfigKey", "participantConfigValue");
    } catch (Exception e) {
      Assert

View Full Code Here

0 1 2 3 4 5 6

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.