List of updateParticipant() Examples

Examples of updateParticipant()

org.apache.helix.api.accessor.ClusterAccessor.updateParticipant()
Update a participant configuration @param participantId the participant to update @param participantDelta changes to the participant @return ParticipantConfig, or null if participant is not persisted
org.apache.helix.api.accessor.ParticipantAccessor.updateParticipant()
Update a participant configuration @param participantId the participant to update @param participantDelta changes to the participant @return ParticipantConfig, or null if participant is not persisted
org.eclipse.jdt.internal.core.search.indexing.IndexManager.updateParticipant()

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

  private static void updateParticipant(ParticipantConfig participant, ClusterId clusterId, HelixConnection connection) {
    // add a tag to the participant and change the hostname, then update it using a delta
    ClusterAccessor accessor = connection.createClusterAccessor(clusterId);
    ParticipantConfig.Delta delta =
        new ParticipantConfig.Delta(participant.getId()).addTag("newTag").setHostName("newHost");
    accessor.updateParticipant(participant.getId(), delta);
  }


  private static void updateResource(ResourceConfig resource, ClusterId clusterId, HelixConnection connection) {
    // add some fields to the resource user config, then update it using the resource config delta
    ClusterAccessor accessor = connection.createClusterAccessor(clusterId);

View Full Code Here

Examples of org.apache.helix.api.accessor.ParticipantAccessor.updateParticipant()

      HelixConnection connection) {
    // add a tag to the participant and change the hostname, then update it using a delta
    ParticipantAccessor accessor = connection.createParticipantAccessor(clusterId);
    ParticipantConfig.Delta delta =
        new ParticipantConfig.Delta(participant.getId()).addTag("newTag").setHostName("newHost");
    accessor.updateParticipant(participant.getId(), delta);
  }


  private static void updateResource(ResourceConfig resource, ClusterId clusterId,
      HelixConnection connection) {
    // add some fields to the resource user config, then update it using the resource config delta

View Full Code Here

Examples of org.apache.helix.api.accessor.ParticipantAccessor.updateParticipant()

    ParticipantAccessor accessor = participantAccessor(clusterName);
    ParticipantId participantId = ParticipantId.from(participantName);


    ParticipantConfig.Delta delta = new ParticipantConfig.Delta(participantId);
    delta.addTag(tag);
    accessor.updateParticipant(participantId, delta);
  }


  void removeInstanceTag(String[] optValues) {
    String clusterName = optValues[0];
    String participantName = optValues[1];

View Full Code Here

Examples of org.apache.helix.api.accessor.ParticipantAccessor.updateParticipant()

    ParticipantAccessor accessor = participantAccessor(clusterName);
    ParticipantId participantId = ParticipantId.from(participantName);


    ParticipantConfig.Delta delta = new ParticipantConfig.Delta(participantId);
    delta.removeTag(tag);
    accessor.updateParticipant(participantId, delta);
  }


  void listPartitionInfo(String[] optValues) {
    String clusterName = optValues[0];
    String resourceName = optValues[1];

View Full Code Here

Examples of org.eclipse.jdt.internal.core.search.indexing.IndexManager.updateParticipant()

    IndexManager manager = JavaModelManager.getIndexManager();
    // TODO (frederic) should not have to create index manually, should expose API that recreates index instead
    manager.ensureIndexExists(indexLocation, containerPath);
    manager.scheduleDocumentIndexing(document, containerPath, indexLocation, this);
    if (!indexLocation.equals(this.lastIndexLocation)) {
      manager.updateParticipant(indexLocation, containerPath);
      this.lastIndexLocation = indexLocation;
    }
  }


  /**

View Full Code Here

Examples of org.eclipse.jdt.internal.core.search.indexing.IndexManager.updateParticipant()

    IndexLocation indexLocation;
    indexLocation = new FileIndexLocation(indexPath.toFile(), true);
    manager.ensureIndexExists(indexLocation, containerPath);
    manager.scheduleDocumentIndexing(document, containerPath, indexLocation, this);
    if (!indexPath.equals(this.lastIndexLocation)) {
      manager.updateParticipant(indexPath, containerPath);
      this.lastIndexLocation = indexPath;
    }
  }


  /**

View Full Code Here

Examples of org.eclipse.jdt.internal.core.search.indexing.IndexManager.updateParticipant()

    IndexLocation indexLocation;
    indexLocation = new FileIndexLocation(indexPath.toFile(), true);
    manager.ensureIndexExists(indexLocation, containerPath);
    manager.scheduleDocumentIndexing(document, containerPath, indexLocation, this);
    if (!indexPath.equals(this.lastIndexLocation)) {
      manager.updateParticipant(indexPath, containerPath);
      this.lastIndexLocation = indexPath;
    }
  }


  /**

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.