com.datastax.driver.core.policies.Policies.defaultLoadBalancingPolicy()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(9.6k)|赞(0)|评价(0)|浏览(185)

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

Policies.defaultLoadBalancingPolicy介绍

[英]The default load balancing policy.

The default load balancing policy is com.yugabyte.driver.core.policies.PartitionAwarePolicy with data-center awareness (so new PartitionAwarePolicy(new DCAwareRoundRobinPolicy.Builder().build())).
[中]默认的负载平衡策略。
默认的负载平衡策略是com。尤加比特。驾驶员果心政策。具有数据中心意识的PartitionAwarePolicy（so new PartitionAwarePolicy（new DCAwareRoundRobinPolicy.Builder（））。build（）））。

代码示例

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

/**
  * Builds the final object from this builder.
  *
  * <p>Any field that hasn't been set explicitly will get its default value.
  *
  * @return the object.
  */
 public Policies build() {
  return new Policies(
    loadBalancingPolicy == null ? defaultLoadBalancingPolicy() : loadBalancingPolicy,
    reconnectionPolicy == null ? defaultReconnectionPolicy() : reconnectionPolicy,
    retryPolicy == null ? defaultRetryPolicy() : retryPolicy,
    addressTranslator == null ? defaultAddressTranslator() : addressTranslator,
    timestampGenerator == null ? defaultTimestampGenerator() : timestampGenerator,
    speculativeExecutionPolicy == null
      ? defaultSpeculativeExecutionPolicy()
      : speculativeExecutionPolicy);
 }
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

@Override
public Cluster.Builder createClusterBuilder() {
 policy = new CloseMonitoringPolicy(Policies.defaultLoadBalancingPolicy());
 return Cluster.builder()
   .addContactPoints(getContactPoints().get(0))
   .withLoadBalancingPolicy(policy);
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

private void deleteNode2RpcAddressFromNode1() throws Exception {
  InetSocketAddress firstHost = ccm().addressOfNode(1);
  Cluster cluster =
    register(
      Cluster.builder()
        .addContactPoints(firstHost.getAddress())
        .withPort(ccm().getBinaryPort())
        // ensure we will only connect to node1
        .withLoadBalancingPolicy(
          new WhiteListPolicy(
            Policies.defaultLoadBalancingPolicy(), Lists.newArrayList(firstHost)))
        .build());
  Session session = cluster.connect();
  String deleteStmt =
    String.format(
      "DELETE rpc_address FROM system.peers WHERE peer = '%s'",
      ccm().addressOfNode(2).getHostName());
  session.execute(deleteStmt);
  session.close();
  cluster.close();
 }
}

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

new QueryPlanCountingPolicy(Policies.defaultLoadBalancingPolicy());
AtomicInteger reconnectionAttempts = loadBalancingPolicy.counter;

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

LoadBalancingPolicy firstHostOnlyPolicy =
  new WhiteListPolicy(
    Policies.defaultLoadBalancingPolicy(),
    Collections.singletonList(host1.getSocketAddress()));

代码示例来源：origin: com.datastax.cassandra/cassandra-driver-core

public void should_receive_changes_made_while_control_connection_is_down_on_reconnect()
  throws Exception {
 ToggleablePolicy lbPolicy = new ToggleablePolicy(Policies.defaultLoadBalancingPolicy());
 Cluster cluster =
   register(

代码示例来源：origin: cumulusrdf/cumulusrdf

/**
 * Returns the load balancing policy according with a given configuration.
 * 
 * @param configuration the configuration.
 * @return the load balancing policy according with a given configuration.
 */
private LoadBalancingPolicy loadBalancingPolicy(final Configuration<Map<String, Object>> configuration) {
  LoadBalancingPolicy lbPolicy = Policies.defaultLoadBalancingPolicy();
  try {
    String lbPolicyClassName = configuration.getAttribute(LOAD_BALANCING_POLICY, null);
    if (lbPolicyClassName != null) {
      lbPolicy = (LoadBalancingPolicy) Class.forName(lbPolicyClassName).newInstance();                        
    }
  } catch (final Exception ignore) {
    // just use the default value.
  }
  return lbPolicy;
}

代码示例来源：origin: cumulusrdf/cumulusrdf

/**
 * Returns the load balancing policy according with a given configuration.
 * 
 * @param configuration the configuration.
 * @return the load balancing policy according with a given configuration.
 */
private LoadBalancingPolicy loadBalancingPolicy(final Configuration<Map<String, Object>> configuration) {
  LoadBalancingPolicy lbPolicy = Policies.defaultLoadBalancingPolicy();
  try {
    String lbPolicyClassName = configuration.getAttribute(LOAD_BALANCING_POLICY, null);
    if (lbPolicyClassName != null) {
      lbPolicy = (LoadBalancingPolicy) Class.forName(lbPolicyClassName).newInstance();                        
    }
  } catch (final Exception ignore) {
    // just use the default value.
  }
  return lbPolicy;
}

代码示例来源：origin: com.stratio.cassandra/cassandra-driver-core

public Policies() {
  this(defaultLoadBalancingPolicy(), defaultReconnectionPolicy(), defaultRetryPolicy(), defaultAddressTranslater());
}

代码示例来源：origin: bazaarvoice/emodb

_loadBalancingPolicy = Objects.firstNonNull(_loadBalancingPolicy, Policies.defaultLoadBalancingPolicy());
_retryPolicy = Objects.firstNonNull(_retryPolicy, Policies.defaultRetryPolicy());

代码示例来源：origin: com.bazaarvoice.emodb/emodb-common-astyanax

_loadBalancingPolicy = Objects.firstNonNull(_loadBalancingPolicy, Policies.defaultLoadBalancingPolicy());
_retryPolicy = Objects.firstNonNull(_retryPolicy, Policies.defaultRetryPolicy());

代码示例来源：origin: com.stratio.deep/deep-cassandra

LoadBalancingPolicy loadBalancingPolicy = balanced ? Policies.defaultLoadBalancingPolicy() : new
    LocalMachineLoadBalancingPolicy(locationInet);

代码示例来源：origin: com.yugabyte/cassandra-driver-core

/**
   * Builds the final object from this builder.
   * <p/>
   * Any field that hasn't been set explicitly will get its default value.
   *
   * @return the object.
   */
  public Policies build() {
    return new Policies(
        loadBalancingPolicy == null ? defaultLoadBalancingPolicy() : loadBalancingPolicy,
        reconnectionPolicy == null ? defaultReconnectionPolicy() : reconnectionPolicy,
        retryPolicy == null ? defaultRetryPolicy() : retryPolicy,
        addressTranslator == null ? defaultAddressTranslator() : addressTranslator,
        timestampGenerator == null ? defaultTimestampGenerator() : timestampGenerator,
        speculativeExecutionPolicy == null ? defaultSpeculativeExecutionPolicy() : speculativeExecutionPolicy);
  }
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

@Override
public Cluster.Builder createClusterBuilder() {
 policy = new CloseMonitoringPolicy(Policies.defaultLoadBalancingPolicy());
 return Cluster.builder()
   .addContactPoints(getContactPoints().get(0))
   .withLoadBalancingPolicy(policy);
}

代码示例来源：origin: io.prestosql.cassandra/cassandra-driver

/**
   * Builds the final object from this builder.
   * <p/>
   * Any field that hasn't been set explicitly will get its default value.
   *
   * @return the object.
   */
  public Policies build() {
    return new Policies(
        loadBalancingPolicy == null ? Policies.defaultLoadBalancingPolicy() : loadBalancingPolicy,
        Objects.firstNonNull(reconnectionPolicy, Policies.defaultReconnectionPolicy()),
        Objects.firstNonNull(retryPolicy, Policies.defaultRetryPolicy()),
        Objects.firstNonNull(addressTranslator, Policies.defaultAddressTranslator()),
        Objects.firstNonNull(timestampGenerator, Policies.defaultTimestampGenerator()),
        Objects.firstNonNull(speculativeExecutionPolicy, Policies.defaultSpeculativeExecutionPolicy()));
  }
}

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-driver

/**
   * Builds the final object from this builder.
   * <p/>
   * Any field that hasn't been set explicitly will get its default value.
   *
   * @return the object.
   */
  public Policies build() {
    return new Policies(
        loadBalancingPolicy == null ? Policies.defaultLoadBalancingPolicy() : loadBalancingPolicy,
        Objects.firstNonNull(reconnectionPolicy, Policies.defaultReconnectionPolicy()),
        Objects.firstNonNull(retryPolicy, Policies.defaultRetryPolicy()),
        Objects.firstNonNull(addressTranslator, Policies.defaultAddressTranslator()),
        Objects.firstNonNull(timestampGenerator, Policies.defaultTimestampGenerator()),
        Objects.firstNonNull(speculativeExecutionPolicy, Policies.defaultSpeculativeExecutionPolicy()));
  }
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

private void deleteNode2RpcAddressFromNode1() throws Exception {
  InetSocketAddress firstHost = ccm().addressOfNode(1);
  Cluster cluster =
    register(
      Cluster.builder()
        .addContactPoints(firstHost.getAddress())
        .withPort(ccm().getBinaryPort())
        // ensure we will only connect to node1
        .withLoadBalancingPolicy(
          new WhiteListPolicy(
            Policies.defaultLoadBalancingPolicy(), Lists.newArrayList(firstHost)))
        .build());
  Session session = cluster.connect();
  String deleteStmt =
    String.format(
      "DELETE rpc_address FROM system.peers WHERE peer = '%s'",
      ccm().addressOfNode(2).getHostName());
  session.execute(deleteStmt);
  session.close();
  cluster.close();
 }
}

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

new QueryPlanCountingPolicy(Policies.defaultLoadBalancingPolicy());
AtomicInteger reconnectionAttempts = loadBalancingPolicy.counter;

代码示例来源：origin: com.datastax.dse/dse-java-driver-core

LoadBalancingPolicy firstHostOnlyPolicy =
  new WhiteListPolicy(
    Policies.defaultLoadBalancingPolicy(),
    Collections.singletonList(host1.getSocketAddress()));

代码示例来源：origin: com.stratio.cassandra/cassandra-driver-core

/**
 * The configuration that will be used for the new cluster.
 * <p>
 * You <b>should not</b> modify this object directly because changes made
 * to the returned object may not be used by the cluster build.
 * Instead, you should use the other methods of this {@code Builder}.
 *
 * @return the configuration to use for the new cluster.
 */
@Override
public Configuration getConfiguration() {
  Policies policies = new Policies(
    loadBalancingPolicy == null ? Policies.defaultLoadBalancingPolicy() : loadBalancingPolicy,
    reconnectionPolicy == null ? Policies.defaultReconnectionPolicy() : reconnectionPolicy,
    retryPolicy == null ? Policies.defaultRetryPolicy() : retryPolicy,
    addressTranslater == null ? Policies.defaultAddressTranslater() : addressTranslater
  );
  return new Configuration(policies,
               new ProtocolOptions(port, protocolVersion, sslOptions, authProvider).setCompression(compression),
               poolingOptions == null ? new PoolingOptions() : poolingOptions,
               socketOptions == null ? new SocketOptions() : socketOptions,
               metricsEnabled ? new MetricsOptions(jmxEnabled) : null,
               queryOptions == null ? new QueryOptions() : queryOptions);
}

内容来源于网络，如有侵权，请联系作者删除！

Policies

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com