You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2013/10/09 01:42:39 UTC

git commit: ACCUMULO-1566 the missing link

Updated Branches:
  refs/heads/ACCUMULO-1566 ff95c7147 -> b4bd20432


ACCUMULO-1566 the missing link


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b4bd2043
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b4bd2043
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b4bd2043

Branch: refs/heads/ACCUMULO-1566
Commit: b4bd204320632b598bee047c620f2e45cc7caef9
Parents: ff95c71
Author: Keith Turner <kt...@apache.org>
Authored: Tue Oct 8 19:42:32 2013 -0400
Committer: Keith Turner <kt...@apache.org>
Committed: Tue Oct 8 19:42:32 2013 -0400

----------------------------------------------------------------------
 .../java/org/apache/accumulo/core/client/impl/ScannerIterator.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/b4bd2043/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerIterator.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerIterator.java b/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerIterator.java
index e9d1412..b202d3a 100644
--- a/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerIterator.java
+++ b/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerIterator.java
@@ -145,7 +145,7 @@ public class ScannerIterator implements Iterator<Entry<Key,Value>> {
     }
     
     scanState = new ScanState(instance, credentials, tableId, authorizations, new Range(range), options.fetchedColumns, size, options.serverSideIteratorList,
-        options.serverSideIteratorOptions, isolated);
+        options.serverSideIteratorOptions, isolated, readaheadThreshold);
     
     // If we want to start readahead immediately, don't wait for hasNext to be called
     if (0l == readaheadThreshold) {