本文整理了Java中com.datastax.driver.core.RegularStatement.isIdempotent
方法的一些代码示例,展示了RegularStatement.isIdempotent
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RegularStatement.isIdempotent
方法的具体详情如下:
包路径:com.datastax.driver.core.RegularStatement
类名称:RegularStatement
方法名:isIdempotent
暂无
代码示例来源:origin: com.datastax.cassandra/cassandra-driver-core
private RegularStatement statementWithIdempotency(Boolean idempotency) {
RegularStatement statement = new SimpleStatement("fake statement");
if (idempotency != null) {
statement.setIdempotent(idempotency);
assertThat(statement.isIdempotent()).isEqualTo(idempotency);
} else {
assertThat(statement.isIdempotent()).isNull();
}
return statement;
}
}
代码示例来源: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.dse/dse-java-driver-core
private RegularStatement statementWithIdempotency(Boolean idempotency) {
RegularStatement statement = new SimpleStatement("fake statement");
if (idempotency != null) {
statement.setIdempotent(idempotency);
assertThat(statement.isIdempotent()).isEqualTo(idempotency);
} else {
assertThat(statement.isIdempotent()).isNull();
}
return statement;
}
}
代码示例来源: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;
}
});
内容来源于网络,如有侵权,请联系作者删除!