From 856bebd5f8bf46293edc083aa1a1e9fadab25e70 Mon Sep 17 00:00:00 2001
From: "Brian S. O'Neill" <bronee@gmail.com>
Date: Wed, 4 May 2011 00:20:02 +0000
Subject: Add support for Query controller and timeouts; remove vestigial
 support for interrupts.

---
 .../carbonado/qe/TestIndexedQueryAnalyzer.java     | 37 ++++++++++++++++++++++
 1 file changed, 37 insertions(+)

(limited to 'src/test/java/com/amazon/carbonado/qe/TestIndexedQueryAnalyzer.java')

diff --git a/src/test/java/com/amazon/carbonado/qe/TestIndexedQueryAnalyzer.java b/src/test/java/com/amazon/carbonado/qe/TestIndexedQueryAnalyzer.java
index 524b532..5861023 100644
--- a/src/test/java/com/amazon/carbonado/qe/TestIndexedQueryAnalyzer.java
+++ b/src/test/java/com/amazon/carbonado/qe/TestIndexedQueryAnalyzer.java
@@ -495,18 +495,36 @@ public class TestIndexedQueryAnalyzer extends TestCase {
             return new ArraySortBuffer<S>();
         }
 
+        public SortBuffer<S> createSortBuffer(Query.Controller controller) {
+            return new ArraySortBuffer<S>();
+        }
+
         public long countAll() {
             throw new UnsupportedOperationException();
         }
 
+        public long countAll(Query.Controller controller) {
+            throw new UnsupportedOperationException();
+        }
+
         public Cursor<S> fetchAll() {
             throw new UnsupportedOperationException();
         }
 
+        public Cursor<S> fetchAll(Query.Controller controller) {
+            throw new UnsupportedOperationException();
+        }
+
         public Cursor<S> fetchOne(StorableIndex<S> index, Object[] identityValues) {
             throw new UnsupportedOperationException();
         }
 
+        public Cursor<S> fetchOne(StorableIndex<S> index, Object[] identityValues,
+                                  Query.Controller controller)
+        {
+            throw new UnsupportedOperationException();
+        }
+
         public Query<?> indexEntryQuery(StorableIndex<S> index) {
             return new EmptyQuery();
         }
@@ -516,6 +534,12 @@ public class TestIndexedQueryAnalyzer extends TestCase {
             throw new UnsupportedOperationException();
         }
 
+        public Cursor<S> fetchFromIndexEntryQuery(StorableIndex<S> index, Query<?> indexEntryQuery,
+                                                  Query.Controller controller)
+        {
+            throw new UnsupportedOperationException();
+        }
+
         public Cursor<S> fetchSubset(StorableIndex<S> index,
                                      Object[] identityValues,
                                      BoundaryType rangeStartBoundary,
@@ -527,5 +551,18 @@ public class TestIndexedQueryAnalyzer extends TestCase {
         {
             throw new UnsupportedOperationException();
         }
+
+        public Cursor<S> fetchSubset(StorableIndex<S> index,
+                                     Object[] identityValues,
+                                     BoundaryType rangeStartBoundary,
+                                     Object rangeStartValue,
+                                     BoundaryType rangeEndBoundary,
+                                     Object rangeEndValue,
+                                     boolean reverseRange,
+                                     boolean reverseOrder,
+                                     Query.Controller controller)
+        {
+            throw new UnsupportedOperationException();
+        }
     }
 }
-- 
cgit v1.2.3