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

QuorumConfig.getQuorumFunctionImplementation介绍

暂无

代码示例

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

private void validateQuorumConfig(QuorumConfig quorumConfig) {
  if (quorumConfig.getQuorumFunctionImplementation() == null) {
    return;
  }
  QuorumFunction quorumFunction = quorumConfig.getQuorumFunctionImplementation();
  if (quorumFunction instanceof ProbabilisticQuorumFunction) {
    validateQuorumParameters(quorumConfig.getName(),
        ((ProbabilisticQuorumFunction) quorumFunction).getAcceptableHeartbeatPauseMillis(),
        "acceptable heartbeat pause");
  } else if (quorumFunction instanceof RecentlyActiveQuorumFunction) {
    validateQuorumParameters(quorumConfig.getName(),
        ((RecentlyActiveQuorumFunction) quorumFunction).getHeartbeatToleranceMillis(),
        "heartbeat tolerance");
  }
}

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

private void validateQuorumConfig(QuorumConfig quorumConfig) {
  if (quorumConfig.getQuorumFunctionImplementation() == null) {
    return;
  }
  QuorumFunction quorumFunction = quorumConfig.getQuorumFunctionImplementation();
  if (quorumFunction instanceof ProbabilisticQuorumFunction) {
    validateQuorumParameters(quorumConfig.getName(),
        ((ProbabilisticQuorumFunction) quorumFunction).getAcceptableHeartbeatPauseMillis(),
        "acceptable heartbeat pause");
  } else if (quorumFunction instanceof RecentlyActiveQuorumFunction) {
    validateQuorumParameters(quorumConfig.getName(),
        ((RecentlyActiveQuorumFunction) quorumFunction).getHeartbeatToleranceMillis(),
        "heartbeat tolerance");
  }
}

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

private static void handleQuorumFunction(XmlGenerator gen, QuorumConfig quorumConfig) {
  if (quorumConfig.getQuorumFunctionImplementation() instanceof ProbabilisticQuorumFunction) {
    ProbabilisticQuorumFunction qf = (ProbabilisticQuorumFunction) quorumConfig.getQuorumFunctionImplementation();
    long acceptableHeartbeatPause = qf.getAcceptableHeartbeatPauseMillis();
    double threshold = qf.getSuspicionThreshold();
    int maxSampleSize = qf.getMaxSampleSize();
    long minStdDeviation = qf.getMinStdDeviationMillis();
    long firstHeartbeatEstimate = qf.getHeartbeatIntervalMillis();
    gen.open("probabilistic-quorum", "acceptable-heartbeat-pause-millis", acceptableHeartbeatPause,
        "suspicion-threshold", threshold,
        "max-sample-size", maxSampleSize,
        "min-std-deviation-millis", minStdDeviation,
        "heartbeat-interval-millis", firstHeartbeatEstimate);
    gen.close();
  } else if (quorumConfig.getQuorumFunctionImplementation() instanceof RecentlyActiveQuorumFunction) {
    RecentlyActiveQuorumFunction qf = (RecentlyActiveQuorumFunction) quorumConfig.getQuorumFunctionImplementation();
    gen.open("recently-active-quorum", "heartbeat-tolerance-millis", qf.getHeartbeatToleranceMillis());
    gen.close();
  } else {
    gen.node("quorum-function-class-name", classNameOrImplClass(quorumConfig.getQuorumFunctionClassName(),
        quorumConfig.getQuorumFunctionImplementation()));
  }
}

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

private static void handleQuorumFunction(XmlGenerator gen, QuorumConfig quorumConfig) {
  if (quorumConfig.getQuorumFunctionImplementation() instanceof ProbabilisticQuorumFunction) {
    ProbabilisticQuorumFunction qf = (ProbabilisticQuorumFunction) quorumConfig.getQuorumFunctionImplementation();
    long acceptableHeartbeatPause = qf.getAcceptableHeartbeatPauseMillis();
    double threshold = qf.getSuspicionThreshold();
    int maxSampleSize = qf.getMaxSampleSize();
    long minStdDeviation = qf.getMinStdDeviationMillis();
    long firstHeartbeatEstimate = qf.getHeartbeatIntervalMillis();
    gen.open("probabilistic-quorum", "acceptable-heartbeat-pause-millis", acceptableHeartbeatPause,
        "suspicion-threshold", threshold,
        "max-sample-size", maxSampleSize,
        "min-std-deviation-millis", minStdDeviation,
        "heartbeat-interval-millis", firstHeartbeatEstimate);
    gen.close();
  } else if (quorumConfig.getQuorumFunctionImplementation() instanceof RecentlyActiveQuorumFunction) {
    RecentlyActiveQuorumFunction qf = (RecentlyActiveQuorumFunction) quorumConfig.getQuorumFunctionImplementation();
    gen.open("recently-active-quorum", "heartbeat-tolerance-millis", qf.getHeartbeatToleranceMillis());
    gen.close();
  } else {
    gen.node("quorum-function-class-name", classNameOrImplClass(quorumConfig.getQuorumFunctionClassName(),
        quorumConfig.getQuorumFunctionImplementation()));
  }
}

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

constructedConfig.getQuorumFunctionImplementation());

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

constructedConfig.getQuorumFunctionImplementation());

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

constructedConfig.getQuorumFunctionImplementation());

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

private QuorumFunction initializeQuorumFunction() {
  QuorumFunction quorumFunction = config.getQuorumFunctionImplementation();
  if (quorumFunction == null && config.getQuorumFunctionClassName() != null) {
    try {
      quorumFunction = newInstance(nodeEngine.getConfigClassLoader(), config.getQuorumFunctionClassName());
    } catch (Exception e) {
      throw rethrow(e);
    }
  }
  if (quorumFunction == null) {
    quorumFunction = new MemberCountQuorumFunction(size);
  }
  ManagedContext managedContext = nodeEngine.getSerializationService().getManagedContext();
  quorumFunction = (QuorumFunction) managedContext.initialize(quorumFunction);
  return quorumFunction;
}

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

private QuorumFunction initializeQuorumFunction() {
  QuorumFunction quorumFunction = config.getQuorumFunctionImplementation();
  if (quorumFunction == null && config.getQuorumFunctionClassName() != null) {
    try {
      quorumFunction = newInstance(nodeEngine.getConfigClassLoader(), config.getQuorumFunctionClassName());
    } catch (Exception e) {
      throw rethrow(e);
    }
  }
  if (quorumFunction == null) {
    quorumFunction = new MemberCountQuorumFunction(size);
  }
  ManagedContext managedContext = nodeEngine.getSerializationService().getManagedContext();
  quorumFunction = (QuorumFunction) managedContext.initialize(quorumFunction);
  return quorumFunction;
}