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

Node.getPartitionService介绍

暂无

代码示例

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public InternalPartitionService getPartitionService() {
  return node.getPartitionService();
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public InternalPartitionService getPartitionService() {
  return node.getPartitionService();
}

代码示例来源：origin: hazelcast/hazelcast-jet

int asyncBackups(int requestedSyncBackups, int requestedAsyncBackups, boolean syncForced) {
  if (syncForced || requestedAsyncBackups == 0) {
    // if syncForced, then there will never be any async backups (they are forced to become sync)
    // if there are no asyncBackups then we are also done.
    return 0;
  }
  InternalPartitionService partitionService = node.getPartitionService();
  int maxBackupCount = partitionService.getMaxAllowedBackupCount();
  return min(maxBackupCount - requestedSyncBackups, requestedAsyncBackups);
}

代码示例来源：origin: hazelcast/hazelcast-jet

int syncBackups(int requestedSyncBackups, int requestedAsyncBackups, boolean syncForced) {
  if (syncForced) {
    // if force sync enabled, then the sum of the backups
    requestedSyncBackups += requestedAsyncBackups;
  }
  InternalPartitionService partitionService = node.getPartitionService();
  int maxBackupCount = partitionService.getMaxAllowedBackupCount();
  return min(maxBackupCount, requestedSyncBackups);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

int syncBackups(int requestedSyncBackups, int requestedAsyncBackups, boolean syncForced) {
  if (syncForced) {
    // if force sync enabled, then the sum of the backups
    requestedSyncBackups += requestedAsyncBackups;
  }
  InternalPartitionService partitionService = node.getPartitionService();
  int maxBackupCount = partitionService.getMaxAllowedBackupCount();
  return min(maxBackupCount, requestedSyncBackups);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

int asyncBackups(int requestedSyncBackups, int requestedAsyncBackups, boolean syncForced) {
  if (syncForced || requestedAsyncBackups == 0) {
    // if syncForced, then there will never be any async backups (they are forced to become sync)
    // if there are no asyncBackups then we are also done.
    return 0;
  }
  InternalPartitionService partitionService = node.getPartitionService();
  int maxBackupCount = partitionService.getMaxAllowedBackupCount();
  return min(maxBackupCount - requestedSyncBackups, requestedAsyncBackups);
}

代码示例来源：origin: hazelcast/hazelcast-jet

void sendMembershipEvents(Collection<MemberImpl> currentMembers, Collection<MemberImpl> newMembers) {
  Set<Member> eventMembers = new LinkedHashSet<Member>(currentMembers);
  if (!newMembers.isEmpty()) {
    for (MemberImpl newMember : newMembers) {
      // sync calls
      node.getPartitionService().memberAdded(newMember);
      node.getNodeExtension().onMemberListChange();
      // async events
      eventMembers.add(newMember);
      sendMembershipEventNotifications(newMember, unmodifiableSet(new LinkedHashSet<Member>(eventMembers)), true);
    }
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void checkMigrationsAndPartitionStateVersion(ClusterStateChange stateChange, int partitionStateVersion) {
  final InternalPartitionService partitionService = node.getPartitionService();
  final int thisPartitionStateVersion = partitionService.getPartitionStateVersion();
  if (partitionService.hasOnGoingMigrationLocal()) {
    throw new IllegalStateException("Still have pending migration tasks, "
        + "cannot lock cluster state! New state: " + stateChange
        + ", current state: " + getState());
  } else if (partitionStateVersion != thisPartitionStateVersion) {
    throw new IllegalStateException("Can not lock cluster state! Partition tables have different versions! "
        + "Expected version: " + partitionStateVersion + " Current version: " + thisPartitionStateVersion);
  }
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void checkMigrationsAndPartitionStateVersion(ClusterStateChange stateChange, int partitionStateVersion) {
  final InternalPartitionService partitionService = node.getPartitionService();
  final int thisPartitionStateVersion = partitionService.getPartitionStateVersion();
  if (partitionService.hasOnGoingMigrationLocal()) {
    throw new IllegalStateException("Still have pending migration tasks, "
        + "cannot lock cluster state! New state: " + stateChange
        + ", current state: " + getState());
  } else if (partitionStateVersion != thisPartitionStateVersion) {
    throw new IllegalStateException("Can not lock cluster state! Partition tables have different versions! "
        + "Expected version: " + partitionStateVersion + " Current version: " + thisPartitionStateVersion);
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void changeClusterState(ClusterState newState, boolean isTransient) {
  int partitionStateVersion = node.getPartitionService().getPartitionStateVersion();
  clusterStateManager.changeClusterState(ClusterStateChange.from(newState), membershipManager.getMemberMap(),
      partitionStateVersion, isTransient);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public void changeClusterVersion(Version version) {
  int partitionStateVersion = node.getPartitionService().getPartitionStateVersion();
  clusterStateManager.changeClusterState(ClusterStateChange.from(version), membershipManager.getMemberMap(),
      partitionStateVersion, false);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void changeClusterState(ClusterState newState, boolean isTransient) {
  int partitionStateVersion = node.getPartitionService().getPartitionStateVersion();
  clusterStateManager.changeClusterState(ClusterStateChange.from(newState), membershipManager.getMemberMap(),
      partitionStateVersion, isTransient);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public void changeClusterVersion(Version version, TransactionOptions options) {
  int partitionStateVersion = node.getPartitionService().getPartitionStateVersion();
  clusterStateManager.changeClusterState(ClusterStateChange.from(version), membershipManager.getMemberMap(),
      options, partitionStateVersion, false);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

void onMemberRemove(MemberImpl deadMember) {
  // sync calls
  node.getPartitionService().memberRemoved(deadMember);
  nodeEngine.onMemberLeft(deadMember);
  node.getNodeExtension().onMemberListChange();
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void changeClusterState(ClusterState newState, TransactionOptions options, boolean isTransient) {
  int partitionStateVersion = node.getPartitionService().getPartitionStateVersion();
  clusterStateManager.changeClusterState(ClusterStateChange.from(newState), membershipManager.getMemberMap(),
      options, partitionStateVersion, isTransient);
}

代码示例来源：origin: hazelcast/hazelcast-jet

void onMemberRemove(MemberImpl deadMember) {
  // sync calls
  node.getPartitionService().memberRemoved(deadMember);
  nodeEngine.onMemberLeft(deadMember);
  node.getNodeExtension().onMemberListChange();
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void changeClusterState(ClusterState newState, TransactionOptions options, boolean isTransient) {
  int partitionStateVersion = node.getPartitionService().getPartitionStateVersion();
  clusterStateManager.changeClusterState(ClusterStateChange.from(newState), membershipManager.getMemberMap(),
      options, partitionStateVersion, isTransient);
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public void changeClusterVersion(Version version, TransactionOptions options) {
  int partitionStateVersion = node.getPartitionService().getPartitionStateVersion();
  clusterStateManager.changeClusterState(ClusterStateChange.from(version), membershipManager.getMemberMap(),
      options, partitionStateVersion, false);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void registerCoreServices() {
  logger.finest("Registering core services...");
  Node node = nodeEngine.getNode();
  registerService(ClusterServiceImpl.SERVICE_NAME, node.getClusterService());
  registerService(InternalPartitionService.SERVICE_NAME, node.getPartitionService());
  registerService(ProxyServiceImpl.SERVICE_NAME, nodeEngine.getProxyService());
  registerService(TransactionManagerServiceImpl.SERVICE_NAME, nodeEngine.getTransactionManagerService());
  registerService(ClientEngineImpl.SERVICE_NAME, node.clientEngine);
  registerService(QuorumServiceImpl.SERVICE_NAME, nodeEngine.getQuorumService());
  registerService(WanReplicationService.SERVICE_NAME, nodeEngine.getWanReplicationService());
  registerService(EventServiceImpl.SERVICE_NAME, nodeEngine.getEventService());
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void registerCoreServices() {
  logger.finest("Registering core services...");
  Node node = nodeEngine.getNode();
  registerService(ClusterServiceImpl.SERVICE_NAME, node.getClusterService());
  registerService(InternalPartitionService.SERVICE_NAME, node.getPartitionService());
  registerService(ProxyServiceImpl.SERVICE_NAME, nodeEngine.getProxyService());
  registerService(TransactionManagerServiceImpl.SERVICE_NAME, nodeEngine.getTransactionManagerService());
  registerService(ClientEngineImpl.SERVICE_NAME, node.clientEngine);
  registerService(QuorumServiceImpl.SERVICE_NAME, nodeEngine.getQuorumService());
  registerService(WanReplicationService.SERVICE_NAME, nodeEngine.getWanReplicationService());
  registerService(EventServiceImpl.SERVICE_NAME, nodeEngine.getEventService());
}