com.datastax.driver.core.RegularStatement.getConsistencyLevel()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(4.3k)|赞(0)|评价(0)|浏览(98)

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

RegularStatement.getConsistencyLevel介绍

暂无

代码示例

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

@Override
 public PreparedStatement apply(PreparedStatement prepared) {
  ProtocolVersion protocolVersion =
    getCluster().getConfiguration().getProtocolOptions().getProtocolVersion();
  ByteBuffer routingKey = statement.getRoutingKey(protocolVersion, codecRegistry);
  if (routingKey != null) prepared.setRoutingKey(routingKey);
  if (statement.getConsistencyLevel() != null)
   prepared.setConsistencyLevel(statement.getConsistencyLevel());
  if (statement.getSerialConsistencyLevel() != null)
   prepared.setSerialConsistencyLevel(statement.getSerialConsistencyLevel());
  if (statement.isTracing()) prepared.enableTracing();
  prepared.setRetryPolicy(statement.getRetryPolicy());
  prepared.setOutgoingPayload(statement.getOutgoingPayload());
  prepared.setIdempotent(statement.isIdempotent());
  return prepared;
 }
});

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

switch (protocolVersion) {
 case V1:
  size += CBUtil.sizeOfConsistencyLevel(getConsistencyLevel());
  break;
 case V2:
 case V4:
 case V5:
  size += CBUtil.sizeOfConsistencyLevel(getConsistencyLevel());
  size += QueryFlag.serializedSize(protocolVersion);
  if (hasValues()) {

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

@Override
  public PreparedStatement apply(PreparedStatement prepared) {
    ByteBuffer routingKey = statement.getRoutingKey();
    if (routingKey != null)
      prepared.setRoutingKey(routingKey);
    prepared.setConsistencyLevel(statement.getConsistencyLevel());
    if (statement.isTracing())
      prepared.enableTracing();
    prepared.setRetryPolicy(statement.getRetryPolicy());
    return prepared;
  }
});

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

@Override
  public PreparedStatement apply(PreparedStatement prepared) {
    ProtocolVersion protocolVersion = getCluster().getConfiguration().getProtocolOptions().getProtocolVersion();
    ByteBuffer routingKey = statement.getRoutingKey(protocolVersion, codecRegistry);
    if (routingKey != null)
      prepared.setRoutingKey(routingKey);
    if (statement.getConsistencyLevel() != null)
      prepared.setConsistencyLevel(statement.getConsistencyLevel());
    if (statement.getSerialConsistencyLevel() != null)
      prepared.setSerialConsistencyLevel(statement.getSerialConsistencyLevel());
    if (statement.isTracing())
      prepared.enableTracing();
    prepared.setRetryPolicy(statement.getRetryPolicy());
    prepared.setOutgoingPayload(statement.getOutgoingPayload());
    prepared.setIdempotent(statement.isIdempotent());
    return prepared;
  }
});

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

@Override
  public PreparedStatement apply(PreparedStatement prepared) {
    ProtocolVersion protocolVersion = getCluster().getConfiguration().getProtocolOptions().getProtocolVersion();
    ByteBuffer routingKey = statement.getRoutingKey(protocolVersion, codecRegistry);
    if (routingKey != null)
      prepared.setRoutingKey(routingKey);
    if (statement.getConsistencyLevel() != null)
      prepared.setConsistencyLevel(statement.getConsistencyLevel());
    if (statement.getSerialConsistencyLevel() != null)
      prepared.setSerialConsistencyLevel(statement.getSerialConsistencyLevel());
    if (statement.isTracing())
      prepared.enableTracing();
    prepared.setRetryPolicy(statement.getRetryPolicy());
    prepared.setOutgoingPayload(statement.getOutgoingPayload());
    prepared.setIdempotent(statement.isIdempotent());
    return prepared;
  }
});

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

@Override
  public PreparedStatement apply(PreparedStatement prepared) {
    ProtocolVersion protocolVersion = getCluster().getConfiguration().getProtocolOptions().getProtocolVersion();
    ByteBuffer routingKey = statement.getRoutingKey(protocolVersion, codecRegistry);
    if (routingKey != null)
      prepared.setRoutingKey(routingKey);
    if (statement.getConsistencyLevel() != null)
      prepared.setConsistencyLevel(statement.getConsistencyLevel());
    if (statement.getSerialConsistencyLevel() != null)
      prepared.setSerialConsistencyLevel(statement.getSerialConsistencyLevel());
    if (statement.isTracing())
      prepared.enableTracing();
    prepared.setRetryPolicy(statement.getRetryPolicy());
    prepared.setOutgoingPayload(statement.getOutgoingPayload());
    prepared.setIdempotent(statement.isIdempotent());
    return prepared;
  }
});

相关文章