Skip to content
Snippets Groups Projects
Commit c6ead6f0 authored by Dan Burkert's avatar Dan Burkert
Browse files

Update Kudu binding to 0.9.0

parent 68dd10c1
No related branches found
No related tags found
No related merge requests found
......@@ -158,6 +158,9 @@ public class KuduYCSBClient extends com.yahoo.ycsb.DB {
schema = new Schema(columns);
CreateTableOptions builder = new CreateTableOptions();
List<String> rangePartitionColumns = new ArrayList<>(1);
rangePartitionColumns.add(KEY);
builder.setRangePartitionColumns(rangePartitionColumns);
builder.setNumReplicas(numReplicas);
// create n-1 split keys, which will end up being n tablets master-side
for (int i = 1; i < numTablets + 0; i++) {
......@@ -229,25 +232,23 @@ public class KuduYCSBClient extends com.yahoo.ycsb.DB {
querySchema = COLUMN_NAMES;
// No need to set the projected columns with the whole schema.
} else {
querySchema = new ArrayList<String>(fields);
querySchema = new ArrayList<>(fields);
scannerBuilder.setProjectedColumnNames(querySchema);
}
KuduPredicate.ComparisonOp comparisonOp;
PartialRow lowerBound = schema.newPartialRow();
lowerBound.addString(0, startkey);
scannerBuilder.lowerBound(lowerBound);
if (recordcount == 1) {
comparisonOp = KuduPredicate.ComparisonOp.EQUAL;
} else {
comparisonOp = KuduPredicate.ComparisonOp.GREATER_EQUAL;
PartialRow upperBound = schema.newPartialRow();
upperBound.addString(0, startkey + '\0');
scannerBuilder.exclusiveUpperBound(upperBound);
}
KuduPredicate keyPredicate = KuduPredicate.newComparisonPredicate(
schema.getColumnByIndex(0),
comparisonOp,
startkey);
KuduScanner scanner = scannerBuilder
.addPredicate(keyPredicate)
.limit(recordcount) // currently noop
.build();
scannerBuilder.limit(recordcount); // currently noop
KuduScanner scanner = scannerBuilder.build();
while (scanner.hasMoreRows()) {
RowResultIterator data = scanner.nextRows();
......
......@@ -79,7 +79,7 @@ LICENSE file.
<geode.version>1.0.0-incubating.M2</geode.version>
<googlebigtable.version>0.2.3</googlebigtable.version>
<infinispan.version>7.2.2.Final</infinispan.version>
<kudu.version>0.8.0</kudu.version>
<kudu.version>0.9.0</kudu.version>
<openjpa.jdbc.version>2.1.1</openjpa.jdbc.version>
<!--<mapkeeper.version>1.0</mapkeeper.version>-->
<mongodb.version>3.0.3</mongodb.version>
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment