DataStax Java Driver: 2.0.10 Released!

Cluster cluster = Cluster.builder()

    .addContactPoint("127.0.0.1")

    .withSpeculativeExecutionPolicy(

        new ConstantSpeculativeExecutionPolicy(

            500, // delay before a new execution is launched

            2    // maximum number of executions

        ))

    .build();

Cluster cluster = ...

QueryLogger queryLogger = QueryLogger.builder(cluster).withConstantThreshold(300).build();

cluster.register(queryLogger);

<logger name="com.datastax.driver.core.QueryLogger.SLOW" level="DEBUG" />

BoundStatement bs = ...

ColumnDefinitions variables = bs.preparedStatement().getVariables();

int index = 0;

for (ColumnDefinitions.Definition variable : variables) {

    DataType type = variable.getType();

    String name = variables.getName(index);

    Object value = bs.getObject(index++);

    logger.debug("Parameter {}={}", name, type.format(value));

}