IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-01-11 08:22:04 -06:00
Code Issues Packages Projects Releases Wiki Activity

add support to CQL 1.9 driver for lbp=RRP

Browse Source
This commit is contained in:
Jonathan Shook 2021-04-29 17:46:12 -05:00
parent 5f66cedd46
commit d49222e123
2 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
driver-cql-shaded/src/main/java/io/nosqlbench/activitytype/cql/core/CQLOptions.java
View File

@ -4,8 +4,8 @@ import com.datastax.driver.core.*;
import com.datastax.driver.core.policies.*;
import io.netty.util.HashedWheelTimer;
import io.nosqlbench.nb.api.errors.BasicError;
import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.net.InetSocketAddress;
import java.util.*;
@ -216,6 +216,13 @@ public class CQLOptions {
String[] args= argslist.isBlank() ? new String[0] : argslist.split(",");
switch (policyname) {
case "RRP":
case "RoundRobinPolicy":
if (policy!=null) {
throw new BasicError("You can't wrap another policy with RRP");
}
policy = new RoundRobinPolicy();
break;
case "WLP":
case "whitelist":
List<InetSocketAddress> sockAddrs = Arrays.stream(args)

6
driver-cql-shaded/src/main/resources/cql-loadbalancing.md
View File

@ -28,6 +28,12 @@ line:
Each supported policy is described in detail below, with the options supported.
### RRP: Round Robin Policy
Format: `RRP()`
**note** You can't wrap another policy with RRP.
### WLP: White List Policy
Format: `WLP(addr,...)`