From f66bb1484b05580b882f53969c298a9071d049eb Mon Sep 17 00:00:00 2001
From: Jean-Daniel Cryans <jdcryans@apache.org>
Date: Tue, 19 Apr 2016 11:34:51 -0700
Subject: [PATCH] [kudu] Use the new KuduPredicate API
Kudu 0.8.0 deprecated how predicates were specified and introduced
a more simple one.
---
.../com/yahoo/ycsb/db/KuduYCSBClient.java | 19 +++++++++++--------
1 file changed, 11 insertions(+), 8 deletions(-)
diff --git a/kudu/src/main/java/com/yahoo/ycsb/db/KuduYCSBClient.java b/kudu/src/main/java/com/yahoo/ycsb/db/KuduYCSBClient.java
index 503c574a..05757b41 100644
--- a/kudu/src/main/java/com/yahoo/ycsb/db/KuduYCSBClient.java
+++ b/kudu/src/main/java/com/yahoo/ycsb/db/KuduYCSBClient.java
@@ -233,17 +233,20 @@ public class KuduYCSBClient extends com.yahoo.ycsb.DB {
scannerBuilder.setProjectedColumnNames(querySchema);
}
- PartialRow lowerBound = schema.newPartialRow();
- lowerBound.addString(0, startkey);
- scannerBuilder.lowerBound(lowerBound);
+ KuduPredicate.ComparisonOp comparisonOp;
if (recordcount == 1) {
- PartialRow upperBound = schema.newPartialRow();
- // Keys are fixed length, just adding something at the end is safe.
- upperBound.addString(0, startkey.concat(" "));
- scannerBuilder.exclusiveUpperBound(upperBound);
+ comparisonOp = KuduPredicate.ComparisonOp.EQUAL;
+ } else {
+ comparisonOp = KuduPredicate.ComparisonOp.GREATER_EQUAL;
}
+ KuduPredicate keyPredicate = KuduPredicate.newComparisonPredicate(
+ schema.getColumnByIndex(0),
+ comparisonOp,
+ startkey);
- KuduScanner scanner = scannerBuilder.limit(recordcount) // currently noop
+ KuduScanner scanner = scannerBuilder
+ .addPredicate(keyPredicate)
+ .limit(recordcount) // currently noop
.build();
while (scanner.hasMoreRows()) {
--
GitLab