From 7af9ff19e872af71adeb26576ec9a3ee0e8e079c Mon Sep 17 00:00:00 2001
From: Andy Kruth <kruthar@gmail.com>
Date: Mon, 22 Feb 2016 11:18:35 -0600
Subject: [PATCH] [orientdb] fixed scan with readallfields
---
.../java/com/yahoo/ycsb/db/OrientDBClient.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/orientdb/src/main/java/com/yahoo/ycsb/db/OrientDBClient.java b/orientdb/src/main/java/com/yahoo/ycsb/db/OrientDBClient.java
index 5ef0014d..d1d29205 100644
--- a/orientdb/src/main/java/com/yahoo/ycsb/db/OrientDBClient.java
+++ b/orientdb/src/main/java/com/yahoo/ycsb/db/OrientDBClient.java
@@ -280,20 +280,20 @@ public class OrientDBClient extends DB {
int entrycount = 0;
final OIndexCursor entries = dictionary.getIndex().iterateEntriesMajor(startkey, true, true);
- if (fields != null && !fields.isEmpty()) {
- while (entries.hasNext() && entrycount < recordcount) {
- final OIdentifiable entry = entries.next();
- final ODocument document = entry.getRecord();
+ while (entries.hasNext() && entrycount < recordcount) {
+ final OIdentifiable entry = entries.next();
+ final ODocument document = entry.getRecord();
- final HashMap<String, ByteIterator> map = new HashMap<String, ByteIterator>();
- result.add(map);
+ final HashMap<String, ByteIterator> map = new HashMap<String, ByteIterator>();
+ result.add(map);
+ if (fields != null && !fields.isEmpty()) {
for (String field : fields) {
map.put(field, new StringByteIterator((String) document.field(field)));
}
-
- entrycount++;
}
+
+ entrycount++;
}
return Status.OK;
--
GitLab