diff --git a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/opdispensers/CqlD4BatchStmtDispenser.java b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/opdispensers/CqlD4BatchStmtDispenser.java index e4ee32a26..ea33ec599 100644 --- a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/opdispensers/CqlD4BatchStmtDispenser.java +++ b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/opdispensers/CqlD4BatchStmtDispenser.java @@ -83,7 +83,7 @@ public class CqlD4BatchStmtDispenser extends Cqld4BaseOpDispenser { } @Override - public Cqld4CqlOp apply(long value) { + public Cqld4CqlOp getOp(long value) { Statement bstmt = opfunc.apply(value); return new Cqld4CqlBatchStatement( getSessionFunc().apply(value), diff --git a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/opmappers/CqlD4BatchStmtMapper.java b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/opmappers/CqlD4BatchStmtMapper.java index 5658c163d..30ed2ed06 100644 --- a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/opmappers/CqlD4BatchStmtMapper.java +++ b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/opmappers/CqlD4BatchStmtMapper.java @@ -48,7 +48,7 @@ public class CqlD4BatchStmtMapper implements OpMapper { */ public OpDispenser apply(ParsedOp op) { - ParsedOp subop = op.getAsSubOp("op_template"); + ParsedOp subop = op.getAsSubOp("op_template", ParsedOp.SubOpNaming.ParentAndSubKey); int repeat = op.getStaticValue("repeat"); OpMapper subopMapper = adapter.getOpMapper(); OpDispenser subopDispenser = subopMapper.apply(subop);