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

QuorumConfig.newProbabilisticQuorumConfigBuilder介绍

[英]Returns a builder for QuorumConfig with the given name using a probabilistic quorum function, for the given quorum size that is enabled by default.
[中]对于默认启用的给定仲裁大小，使用概率仲裁函数返回具有给定名称的QuorumConfig生成器。

代码示例

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

private static QuorumConfig probabilisticQuorumConfig() {
    QuorumConfig quorumConfig = QuorumConfig.newProbabilisticQuorumConfigBuilder(NAME, 2)
        .withAcceptableHeartbeatPauseMillis(60000)
        .withHeartbeatIntervalMillis(5000)
        .withSuspicionThreshold(10)
        .build();
    return quorumConfig;
  }
}

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

private QuorumConfigBuilder handleProbabilisticQuorum(String name, Node node, int quorumSize) {
  QuorumConfigBuilder quorumConfigBuilder;
  long acceptableHeartPause = getLongValue("acceptable-heartbeat-pause-millis",
      getAttribute(node, "acceptable-heartbeat-pause-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_PAUSE_MILLIS);
  double threshold = getDoubleValue("suspicion-threshold",
      getAttribute(node, "suspicion-threshold"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_PHI_THRESHOLD);
  int maxSampleSize = getIntegerValue("max-sample-size",
      getAttribute(node, "max-sample-size"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_SAMPLE_SIZE);
  long minStdDeviation = getLongValue("min-std-deviation-millis",
      getAttribute(node, "min-std-deviation-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_MIN_STD_DEVIATION);
  long heartbeatIntervalMillis = getLongValue("heartbeat-interval-millis",
      getAttribute(node, "heartbeat-interval-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_INTERVAL_MILLIS);
  quorumConfigBuilder = QuorumConfig.newProbabilisticQuorumConfigBuilder(name, quorumSize)
      .withAcceptableHeartbeatPauseMillis(acceptableHeartPause)
      .withSuspicionThreshold(threshold)
      .withHeartbeatIntervalMillis(heartbeatIntervalMillis)
      .withMinStdDeviationMillis(minStdDeviation)
      .withMaxSampleSize(maxSampleSize);
  return quorumConfigBuilder;
}

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

private QuorumConfigBuilder handleProbabilisticQuorum(String name, Node node, int quorumSize) {
  QuorumConfigBuilder quorumConfigBuilder;
  long acceptableHeartPause = getLongValue("acceptable-heartbeat-pause-millis",
      getAttribute(node, "acceptable-heartbeat-pause-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_PAUSE_MILLIS);
  double threshold = getDoubleValue("suspicion-threshold",
      getAttribute(node, "suspicion-threshold"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_PHI_THRESHOLD);
  int maxSampleSize = getIntegerValue("max-sample-size",
      getAttribute(node, "max-sample-size"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_SAMPLE_SIZE);
  long minStdDeviation = getLongValue("min-std-deviation-millis",
      getAttribute(node, "min-std-deviation-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_MIN_STD_DEVIATION);
  long heartbeatIntervalMillis = getLongValue("heartbeat-interval-millis",
      getAttribute(node, "heartbeat-interval-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_INTERVAL_MILLIS);
  quorumConfigBuilder = QuorumConfig.newProbabilisticQuorumConfigBuilder(name, quorumSize)
                   .withAcceptableHeartbeatPauseMillis(acceptableHeartPause)
                   .withSuspicionThreshold(threshold)
                   .withHeartbeatIntervalMillis(heartbeatIntervalMillis)
                   .withMinStdDeviationMillis(minStdDeviation)
                   .withMaxSampleSize(maxSampleSize);
  return quorumConfigBuilder;
}

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

private QuorumConfigBuilder handleProbabilisticQuorum(String name, Node node, int quorumSize) {
  QuorumConfigBuilder quorumConfigBuilder;
  long acceptableHeartPause = getLongValue("acceptable-heartbeat-pause-millis",
      getAttribute(node, "acceptable-heartbeat-pause-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_PAUSE_MILLIS);
  double threshold = getDoubleValue("suspicion-threshold",
      getAttribute(node, "suspicion-threshold"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_PHI_THRESHOLD);
  int maxSampleSize = getIntegerValue("max-sample-size",
      getAttribute(node, "max-sample-size"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_SAMPLE_SIZE);
  long minStdDeviation = getLongValue("min-std-deviation-millis",
      getAttribute(node, "min-std-deviation-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_MIN_STD_DEVIATION);
  long heartbeatIntervalMillis = getLongValue("heartbeat-interval-millis",
      getAttribute(node, "heartbeat-interval-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_INTERVAL_MILLIS);
  quorumConfigBuilder = QuorumConfig.newProbabilisticQuorumConfigBuilder(name, quorumSize)
      .withAcceptableHeartbeatPauseMillis(acceptableHeartPause)
      .withSuspicionThreshold(threshold)
      .withHeartbeatIntervalMillis(heartbeatIntervalMillis)
      .withMinStdDeviationMillis(minStdDeviation)
      .withMaxSampleSize(maxSampleSize);
  return quorumConfigBuilder;
}

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

private QuorumConfigBuilder handleProbabilisticQuorum(String name, Node node, int quorumSize) {
  QuorumConfigBuilder quorumConfigBuilder;
  long acceptableHeartPause = getLongValue("acceptable-heartbeat-pause-millis",
      getAttribute(node, "acceptable-heartbeat-pause-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_PAUSE_MILLIS);
  double threshold = getDoubleValue("suspicion-threshold",
      getAttribute(node, "suspicion-threshold"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_PHI_THRESHOLD);
  int maxSampleSize = getIntegerValue("max-sample-size",
      getAttribute(node, "max-sample-size"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_SAMPLE_SIZE);
  long minStdDeviation = getLongValue("min-std-deviation-millis",
      getAttribute(node, "min-std-deviation-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_MIN_STD_DEVIATION);
  long heartbeatIntervalMillis = getLongValue("heartbeat-interval-millis",
      getAttribute(node, "heartbeat-interval-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_INTERVAL_MILLIS);
  quorumConfigBuilder = QuorumConfig.newProbabilisticQuorumConfigBuilder(name, quorumSize)
      .withAcceptableHeartbeatPauseMillis(acceptableHeartPause)
      .withSuspicionThreshold(threshold)
      .withHeartbeatIntervalMillis(heartbeatIntervalMillis)
      .withMinStdDeviationMillis(minStdDeviation)
      .withMaxSampleSize(maxSampleSize);
  return quorumConfigBuilder;
}

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

private QuorumConfigBuilder handleProbabilisticQuorum(String name, Node node, int quorumSize) {
  QuorumConfigBuilder quorumConfigBuilder;
  long acceptableHeartPause = getLongValue("acceptable-heartbeat-pause-millis",
      getAttribute(node, "acceptable-heartbeat-pause-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_PAUSE_MILLIS);
  double threshold = getDoubleValue("suspicion-threshold",
      getAttribute(node, "suspicion-threshold"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_PHI_THRESHOLD);
  int maxSampleSize = getIntegerValue("max-sample-size",
      getAttribute(node, "max-sample-size"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_SAMPLE_SIZE);
  long minStdDeviation = getLongValue("min-std-deviation-millis",
      getAttribute(node, "min-std-deviation-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_MIN_STD_DEVIATION);
  long heartbeatIntervalMillis = getLongValue("heartbeat-interval-millis",
      getAttribute(node, "heartbeat-interval-millis"),
      ProbabilisticQuorumConfigBuilder.DEFAULT_HEARTBEAT_INTERVAL_MILLIS);
  quorumConfigBuilder = QuorumConfig.newProbabilisticQuorumConfigBuilder(name, quorumSize)
                   .withAcceptableHeartbeatPauseMillis(acceptableHeartPause)
                   .withSuspicionThreshold(threshold)
                   .withHeartbeatIntervalMillis(heartbeatIntervalMillis)
                   .withMinStdDeviationMillis(minStdDeviation)
                   .withMaxSampleSize(maxSampleSize);
  return quorumConfigBuilder;
}