diff options
| author | Brian S. O'Neill <bronee@gmail.com> | 2011-05-04 00:20:02 +0000 |
|---|---|---|
| committer | Brian S. O'Neill <bronee@gmail.com> | 2011-05-04 00:20:02 +0000 |
| commit | 856bebd5f8bf46293edc083aa1a1e9fadab25e70 (patch) | |
| tree | ab8ffc3f5ac1b2d1f2dcfa8942ab8986545c694c /src/test/java/com/amazon/carbonado/qe/TestIndexedQueryAnalyzer.java | |
| parent | 8985b47069e97df435f44b066bdd3be1c9c83407 (diff) | |
Add support for Query controller and timeouts; remove vestigial support for interrupts.
Diffstat (limited to 'src/test/java/com/amazon/carbonado/qe/TestIndexedQueryAnalyzer.java')
| -rw-r--r-- | src/test/java/com/amazon/carbonado/qe/TestIndexedQueryAnalyzer.java | 37 |
1 files changed, 37 insertions, 0 deletions
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();
+ }
}
}
|