public class ConstantSpeculativeExecutionPolicy extends Object implements SpeculativeExecutionPolicy
SpeculativeExecutionPolicythat schedules a given number of speculative executions, separated by a fixed delay.
|Constructor and Description|
Builds a new instance.
|Modifier and Type||Method and Description|
Gets invoked at cluster shutdown.
Gets invoked at cluster startup.
Returns the plan to use for a new query.
public ConstantSpeculativeExecutionPolicy(long constantDelayMillis, int maxSpeculativeExecutions)
constantDelayMillis- the delay between each speculative execution. Must be >= 0. A zero delay means it should immediately send `maxSpeculativeExecutions` requests along with the original request.
maxSpeculativeExecutions- the number of speculative executions. Must be strictly positive.
IllegalArgumentException- if one of the arguments does not respect the preconditions above.
public SpeculativeExecutionPolicy.SpeculativeExecutionPlan newPlan(String loggedKeyspace, Statement statement)
loggedKeyspace- the currently logged keyspace (the one set through either
Cluster.connect(String)or by manually doing a
USEquery) for the session on which this plan need to be built. This can be
nullif the corresponding session has no keyspace logged in.
statement- the query for which to build a plan.
public void init(Cluster cluster)
cluster- the cluster that this policy is associated with.
public void close()
This gives the policy the opportunity to perform some cleanup, for instance stop threads that it might have started.
Copyright © 2012–2023. All rights reserved.