Merge lp:~mmcm/akiban-server/pipeline-spatial-index-scan into lp:~akiban-technologies/akiban-server/trunk

[Mike McMahon]

Pipelining for spatial index scans.

For near point, all subcursors are already being opened at the same time. But the code needs to be adjusted a little to not try to read from any of them then.

For box, add an option to MultiCursor to open all cursors at once. And plumb it around from the IndexScan Cursors, which decide based on whether they are in lookahead mode or not.

[lp:~mmcm/akiban-server/pipeline-spatial-index-scan]

2710. By Mike McMahon on 2013-07-18

Forgot the @Override.

[Thomas Jones-Low (tjoneslo)]

Looks as described.

review: Approve

=== modified file 'src/main/java/com/akiban/qp/memoryadapter/MemoryAdapter.java'
--- src/main/java/com/akiban/qp/memoryadapter/MemoryAdapter.java	2013-07-09 20:37:04 +0000
+++ src/main/java/com/akiban/qp/memoryadapter/MemoryAdapter.java	2013-07-18 20:08:26 +0000
@@ -75,7 +75,7 @@
     @Override
     public RowCursor newIndexCursor(QueryContext context, Index index,
             IndexKeyRange keyRange, Ordering ordering,
-            IndexScanSelector scanSelector, boolean usePValues) {
+            IndexScanSelector scanSelector, boolean usePValues, boolean openAllSubCursors) {
         
         Table table = index.rootMostTable();
         if (table.isUserTable()) {
 
=== modified file 'src/main/java/com/akiban/qp/operator/API.java'
--- src/main/java/com/akiban/qp/operator/API.java	2013-07-17 20:34:35 +0000
+++ src/main/java/com/akiban/qp/operator/API.java	2013-07-18 20:08:26 +0000
@@ -419,6 +419,20 @@
 
     public static Operator indexScan_Default(IndexRowType indexType,
                                              IndexKeyRange indexKeyRange,
+                                             int lookaheadQuantum)
+    {
+        Ordering ordering = new Ordering();
+        int fields = indexType.nFields();
+        for (int f = 0; f < fields; f++) {
+            ordering.append(new TPreparedField(indexType.typeInstanceAt(f), f), true);
+        }
+        IndexScanSelector indexScanSelector = IndexScanSelector.leftJoinAfter(indexType.index(),
+                                                                              indexType.tableType().userTable());
+        return indexScan_Default(indexType, indexKeyRange, ordering, indexScanSelector, lookaheadQuantum);
+    }
+
+    public static Operator indexScan_Default(IndexRowType indexType,
+                                             IndexKeyRange indexKeyRange,
                                              Ordering ordering,
                                              IndexScanSelector indexScanSelector,
                                              int lookaheadQuantum)
 
=== modified file 'src/main/java/com/akiban/qp/operator/IndexScan_Default.java'
--- src/main/java/com/akiban/qp/operator/IndexScan_Default.java	2013-07-15 21:16:57 +0000
+++ src/main/java/com/akiban/qp/operator/IndexScan_Default.java	2013-07-18 20:08:26 +0000
@@ -374,7 +374,7 @@
         {
             super(context, bindingsCursor);
             UserTable table = (UserTable)index.rootMostTable();
-            this.cursor = adapter(table).newIndexCursor(context, index, indexKeyRange, ordering, scanSelector, usePValues);
+            this.cursor = adapter(table).newIndexCursor(context, index, indexKeyRange, ordering, scanSelector, usePValues, false);
         }
 
         // Object state
@@ -576,7 +576,7 @@
             UserTable table = (UserTable)index.rootMostTable();
             StoreAdapter adapter = adapter(table);
             for (int i = 0; i < quantum; i++) {
-                RowCursor cursor = adapter.newIndexCursor(context, index, indexKeyRange, ordering, scanSelector, usePValues);
+                RowCursor cursor = adapter.newIndexCursor(context, index, indexKeyRange, ordering, scanSelector, usePValues, true);
                 cursorPool.add(cursor);
             }
         }
 
=== modified file 'src/main/java/com/akiban/qp/operator/StoreAdapter.java'
--- src/main/java/com/akiban/qp/operator/StoreAdapter.java	2013-07-09 20:37:04 +0000
+++ src/main/java/com/akiban/qp/operator/StoreAdapter.java	2013-07-18 20:08:26 +0000
@@ -57,7 +57,8 @@
                                              IndexKeyRange keyRange,
                                              API.Ordering ordering,
                                              IndexScanSelector scanSelector,
-                                             boolean usePValues);
+                                             boolean usePValues,
+                                             boolean openAllSubCursors);
 
     public abstract <HKEY extends com.akiban.qp.row.HKey> HKEY newHKey(HKey hKeyMetadata);
 
 
=== modified file 'src/main/java/com/akiban/qp/persistitadapter/PersistitAdapter.java'
--- src/main/java/com/akiban/qp/persistitadapter/PersistitAdapter.java	2013-07-13 17:12:00 +0000
+++ src/main/java/com/akiban/qp/persistitadapter/PersistitAdapter.java	2013-07-18 20:08:26 +0000
@@ -72,14 +72,15 @@
 
     @Override
     public RowCursor newIndexCursor(QueryContext context, Index index, IndexKeyRange keyRange, API.Ordering ordering,
-                                 IndexScanSelector selector, boolean usePValues)
+                                    IndexScanSelector selector, boolean usePValues, boolean openAllSubCursors)
     {
         return new PersistitIndexCursor(context,
                                         schema.indexRowType(index),
                                         keyRange,
                                         ordering,
                                         selector,
-                                        usePValues);
+                                        usePValues,
+                                        openAllSubCursors);
     }
 
     @Override
 
=== modified file 'src/main/java/com/akiban/qp/persistitadapter/PersistitIndexCursor.java'
--- src/main/java/com/akiban/qp/persistitadapter/PersistitIndexCursor.java	2013-07-09 17:26:33 +0000
+++ src/main/java/com/akiban/qp/persistitadapter/PersistitIndexCursor.java	2013-07-18 20:08:26 +0000
@@ -116,7 +116,8 @@
                          IndexKeyRange keyRange,
                          API.Ordering ordering,
                          IndexScanSelector selector,
-                         boolean usePValues)
+                         boolean usePValues,
+                         boolean openAllSubCursors)
     {
         this.keyRange = keyRange;
         this.ordering = ordering;
@@ -127,7 +128,7 @@
         this.selector = selector;
         this.idle = true;
         this.rowState = context.getStore().createIterationHelper(indexRowType);
-        this.indexCursor = IndexCursor.create(context, keyRange, ordering, rowState, usePValues);
+        this.indexCursor = IndexCursor.create(context, keyRange, ordering, rowState, usePValues, openAllSubCursors);
     }
 
     // For use by this class
 
=== modified file 'src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursor.java'
--- src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursor.java	2013-07-09 00:42:04 +0000
+++ src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursor.java	2013-07-18 20:08:26 +0000
@@ -128,7 +128,8 @@
                                      IndexKeyRange keyRange,
                                      API.Ordering ordering,
                                      IterationHelper iterationHelper,
-                                     boolean usePValues)
+                                     boolean usePValues,
+                                     boolean openAllSubCursors)
     {
         SortKeyAdapter<?, ?> adapter =
             usePValues
@@ -138,7 +139,7 @@
             keyRange != null && keyRange.spatial()
             ? keyRange.hi() == null
                 ? IndexCursorSpatial_NearPoint.create(context, iterationHelper, keyRange)
-                : IndexCursorSpatial_InBox.create(context, iterationHelper, keyRange)
+                : IndexCursorSpatial_InBox.create(context, iterationHelper, keyRange, openAllSubCursors)
             : ordering.allAscending() || ordering.allDescending()
                 ? (keyRange != null && keyRange.lexicographic()
                     ? IndexCursorUnidirectionalLexicographic.create(context, iterationHelper, keyRange, ordering, adapter)
 
=== modified file 'src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursorSpatial_InBox.java'
--- src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursorSpatial_InBox.java	2013-07-09 17:26:33 +0000
+++ src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursorSpatial_InBox.java	2013-07-18 20:08:26 +0000
@@ -93,18 +93,19 @@
 
     public static IndexCursorSpatial_InBox create(QueryContext context,
                                                   IterationHelper iterationHelper,
-                                                  IndexKeyRange keyRange)
+                                                  IndexKeyRange keyRange,
+                                                  boolean openAll)
     {
-        return  new IndexCursorSpatial_InBox(context, iterationHelper, keyRange);
+        return  new IndexCursorSpatial_InBox(context, iterationHelper, keyRange, openAll);
     }
 
     // For use by this class
 
-    private IndexCursorSpatial_InBox(QueryContext context, IterationHelper iterationHelper, IndexKeyRange keyRange)
+    private IndexCursorSpatial_InBox(QueryContext context, IterationHelper iterationHelper, IndexKeyRange keyRange, boolean openAll)
     {
         super(context, iterationHelper);
         assert keyRange.spatial();
-        this.multiCursor = new MultiCursor();
+        this.multiCursor = new MultiCursor(openAll);
         this.iterationHelper = iterationHelper;
         Index spatialIndex = keyRange.indexRowType().index();
         assert spatialIndex.isSpatial() : spatialIndex;
 
=== modified file 'src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursorSpatial_NearPoint.java'
--- src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursorSpatial_NearPoint.java	2013-07-09 17:26:33 +0000
+++ src/main/java/com/akiban/qp/persistitadapter/indexcursor/IndexCursorSpatial_NearPoint.java	2013-07-18 20:08:26 +0000
@@ -51,16 +51,11 @@
     {
         super.open();
         // iterationHelper.closeIteration() closes the PersistitIndexCursor, releasing its Exchange.
-        // This iteration uses the Exchanges in the IndexScanRowStates owned by each cursor of the MultiCursor.
         iterationHelper.closeIteration();
         geCursor.open();
-        geRow = geCursor.next();
-        geDistance = distanceFromStart(geRow);
-        geNeedToAdvance = false;
+        geNeedToAdvance = true;
         ltCursor.open();
-        ltRow = ltCursor.next();
-        ltDistance = distanceFromStart(ltRow);
-        ltNeedToAdvance = false;
+        ltNeedToAdvance = true;
     }
 
     @Override
@@ -72,7 +67,8 @@
             geRow = geCursor.next();
             geDistance = distanceFromStart(geRow);
             geNeedToAdvance = false;
-        } else if (ltNeedToAdvance) {
+        } 
+        if (ltNeedToAdvance) {
             ltRow = ltCursor.next();
             ltDistance = distanceFromStart(ltRow);
             ltNeedToAdvance = false;
 
=== modified file 'src/main/java/com/akiban/qp/persistitadapter/indexcursor/PersistitSorter.java'
--- src/main/java/com/akiban/qp/persistitadapter/indexcursor/PersistitSorter.java	2013-07-16 18:27:15 +0000
+++ src/main/java/com/akiban/qp/persistitadapter/indexcursor/PersistitSorter.java	2013-07-18 20:08:26 +0000
@@ -147,7 +147,7 @@
     private RowCursor cursor()
     {
         exchange.clear();
-        IndexCursor indexCursor = IndexCursor.create(context, null, ordering, iterationHelper, usePValues);
+        IndexCursor indexCursor = IndexCursor.create(context, null, ordering, iterationHelper, usePValues, false);
         indexCursor.rebind(bindings);
         return indexCursor;
     }
 
=== modified file 'src/main/java/com/akiban/qp/util/MultiCursor.java'
--- src/main/java/com/akiban/qp/util/MultiCursor.java	2013-07-09 19:53:07 +0000
+++ src/main/java/com/akiban/qp/util/MultiCursor.java	2013-07-18 20:08:26 +0000
@@ -34,9 +34,12 @@
     @Override
     public void open()
     {
-        sealed = false;
-        // TODO: Have a mode where all the cursors get opened so that
-        // they can start in parallel.
+        sealed = true;
+        if (openAll) {
+            for (RowCursor cursor : cursors) {
+                cursor.open();
+            }
+        }
         cursorIterator = cursors.iterator();
         startNextCursor();
     }
@@ -109,6 +112,14 @@
 
     // MultiCursor interface
 
+    public MultiCursor() {
+        this(false);
+    }
+
+    public MultiCursor(boolean openAll) {
+        this.openAll = openAll;
+    }
+
     public void addCursor(RowCursor cursor)
     {
         if (sealed) {
@@ -126,7 +137,9 @@
                 current.close();
             }
             current = cursorIterator.next();
-            current.open();
+            if (!openAll) {
+                current.open();
+            }
         } else {
             current = null;
         }
@@ -135,6 +148,7 @@
     // Object state
 
     private final List<RowCursor> cursors = new ArrayList<>();
+    private final boolean openAll;
     private boolean sealed = false;
     private Iterator<RowCursor> cursorIterator;
     private RowCursor current;
 
=== modified file 'src/test/java/com/akiban/qp/operator/OperatorTestHelper.java'
--- src/test/java/com/akiban/qp/operator/OperatorTestHelper.java	2013-07-09 20:37:04 +0000
+++ src/test/java/com/akiban/qp/operator/OperatorTestHelper.java	2013-07-18 20:08:26 +0000
@@ -193,7 +193,8 @@
                                      IndexKeyRange keyRange,
                                      API.Ordering ordering,
                                      IndexScanSelector selector,
-                                     boolean usePValues)
+                                     boolean usePValues,
+                                     boolean openAllSubCursors)
         {
             throw new UnsupportedOperationException();
         }
 
=== modified file 'src/test/java/com/akiban/server/test/it/qp/MultiCursorIT.java'
--- src/test/java/com/akiban/server/test/it/qp/MultiCursorIT.java	2013-07-09 20:37:04 +0000
+++ src/test/java/com/akiban/server/test/it/qp/MultiCursorIT.java	2013-07-18 20:08:26 +0000
@@ -50,6 +50,14 @@
         queryBindings = queryContext.createBindings();
     }
 
+    @Test(expected=IllegalStateException.class)
+    public void testSealed()
+    {
+        MultiCursor multiCursor = multiCursor();
+        multiCursor.open();
+        multiCursor.addCursor(new TestCursor(new int[]{}));
+    }
+
     @Test
     public void testNoCursors()
     {
@@ -84,7 +92,18 @@
     @Test
     public void testMultipleCursors()
     {
-        RowCursor multiCursor = multiCursor(new TestCursor(new int[]{}),
+        testMultipleCursors(false);
+    }
+
+    @Test
+    public void testOpenAll()
+    {
+        testMultipleCursors(true);
+    }
+
+    private void testMultipleCursors(boolean openAll) {
+        RowCursor multiCursor = multiCursor(openAll,
+                                            new TestCursor(new int[]{}),
                                             new TestCursor(new int[]{0, 1, 2}),
                                             new TestCursor(new int[]{}),
                                             new TestCursor(new int[]{}),
@@ -104,7 +123,12 @@
 
     private MultiCursor multiCursor(TestCursor ... cursors)
     {
-        MultiCursor multiCursor = new MultiCursor();
+        return multiCursor(false, cursors);
+    }
+
+    private MultiCursor multiCursor(boolean openAll, TestCursor ... cursors)
+    {
+        MultiCursor multiCursor = new MultiCursor(openAll);
         for (TestCursor cursor : cursors) {
             multiCursor.addCursor(cursor);
         }
 
=== modified file 'src/test/java/com/akiban/server/test/it/qp/SpatialLatLonGroupIndexScanIT.java'
--- src/test/java/com/akiban/server/test/it/qp/SpatialLatLonGroupIndexScanIT.java	2013-07-09 21:10:22 +0000
+++ src/test/java/com/akiban/server/test/it/qp/SpatialLatLonGroupIndexScanIT.java	2013-07-18 20:08:26 +0000
@@ -93,6 +93,10 @@
         queryBindings = queryContext.createBindings();
     }
 
+    protected int lookaheadQuantum() {
+        return 1;
+    }
+
     @Test
     public void testLoad()
     {
@@ -290,7 +294,7 @@
             IndexBound upperRight = new IndexBound(row(pSpatialIndexRowType, beforeEQ, latHi, lonHi),
                                                    new SetColumnSelector(0, 1, 2));
             IndexKeyRange box = IndexKeyRange.spatial(pSpatialIndexRowType, lowerLeft, upperRight);
-            Operator plan = indexScan_Default(pSpatialIndexRowType, false, box);
+            Operator plan = indexScan_Default(pSpatialIndexRowType, box, lookaheadQuantum());
             Cursor cursor = API.cursor(plan, queryContext, queryBindings);
             cursor.openTopLevel();
             Row row;
@@ -369,7 +373,7 @@
             IndexBound upperRight = new IndexBound(row(cSpatialIndexRowType, beforeEQ, latHi, lonHi),
                                                    new SetColumnSelector(0, 1, 2));
             IndexKeyRange box = IndexKeyRange.spatial(cSpatialIndexRowType, lowerLeft, upperRight);
-            Operator plan = indexScan_Default(cSpatialIndexRowType, false, box);
+            Operator plan = indexScan_Default(cSpatialIndexRowType, box, lookaheadQuantum());
             Cursor cursor = API.cursor(plan, queryContext, queryBindings);
             cursor.openTopLevel();
             Row row;
@@ -424,7 +428,7 @@
                     new IndexBound(row(cSpatialIndexRowType, beforeEQ,  queryLat, queryLon),
                                    new SetColumnSelector(0, 1, 2));
                 IndexKeyRange zStartRange = IndexKeyRange.around(cSpatialIndexRowType, zStartBound);
-                Operator plan = indexScan_Default(cSpatialIndexRowType, false, zStartRange);
+                Operator plan = indexScan_Default(cSpatialIndexRowType, zStartRange, lookaheadQuantum());
                 Cursor cursor = API.cursor(plan, queryContext, queryBindings);
                 cursor.openTopLevel();
                 Row row;
 
=== added file 'src/test/java/com/akiban/server/test/it/qp/SpatialLatLonGroupIndexScanLookaheadIT.java'
--- src/test/java/com/akiban/server/test/it/qp/SpatialLatLonGroupIndexScanLookaheadIT.java	1970-01-01 00:00:00 +0000
+++ src/test/java/com/akiban/server/test/it/qp/SpatialLatLonGroupIndexScanLookaheadIT.java	2013-07-18 20:08:26 +0000
@@ -0,0 +1,26 @@
+/**
+ * Copyright (C) 2009-2013 Akiban Technologies, Inc.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+package com.akiban.server.test.it.qp;
+
+public class SpatialLatLonGroupIndexScanLookaheadIT extends SpatialLatLonGroupIndexScanIT
+{
+    @Override
+    protected int lookaheadQuantum() {
+        return 10;
+    }
+}
 
=== modified file 'src/test/java/com/akiban/server/test/it/qp/SpatialLatLonTableIndexScanIT.java'
--- src/test/java/com/akiban/server/test/it/qp/SpatialLatLonTableIndexScanIT.java	2013-07-09 21:10:22 +0000
+++ src/test/java/com/akiban/server/test/it/qp/SpatialLatLonTableIndexScanIT.java	2013-07-18 20:08:26 +0000
@@ -80,6 +80,10 @@
         queryBindings = queryContext.createBindings();
     }
 
+    protected int lookaheadQuantum() {
+        return 1;
+    }
+
     @Test
     public void testLoad()
     {
@@ -341,7 +345,7 @@
             IndexBound upperRight = new IndexBound(row(latLonIndexRowType, latHi, lonHi),
                                                    new SetColumnSelector(0, 1));
             IndexKeyRange box = IndexKeyRange.spatial(latLonIndexRowType, lowerLeft, upperRight);
-            Operator plan = indexScan_Default(latLonIndexRowType, false, box);
+            Operator plan = indexScan_Default(latLonIndexRowType, box, lookaheadQuantum());
             Cursor cursor = API.cursor(plan, queryContext, queryBindings);
             cursor.openTopLevel();
             Row row;
@@ -404,7 +408,7 @@
             IndexBound upperRight = new IndexBound(row(latLonIndexRowType, latHi, lonHi),
                                                    new SetColumnSelector(0, 1));
             IndexKeyRange box = IndexKeyRange.spatial(latLonIndexRowType, lowerLeft, upperRight);
-            Operator plan = indexScan_Default(latLonIndexRowType, false, box);
+            Operator plan = indexScan_Default(latLonIndexRowType, box, lookaheadQuantum());
             Cursor cursor = API.cursor(plan, queryContext, queryBindings);
             cursor.openTopLevel();
             Row row;
@@ -469,7 +473,7 @@
                 IndexBound upperRight = new IndexBound(row(beforeLatLonIndexRowType, before, latHi, lonHi),
                                                        new SetColumnSelector(0, 1, 2));
                 IndexKeyRange box = IndexKeyRange.spatial(beforeLatLonIndexRowType, lowerLeft, upperRight);
-                Operator plan = indexScan_Default(beforeLatLonIndexRowType, false, box);
+                Operator plan = indexScan_Default(beforeLatLonIndexRowType, box, lookaheadQuantum());
                 Cursor cursor = API.cursor(plan, queryContext, queryBindings);
                 cursor.openTopLevel();
                 Row row;
@@ -503,7 +507,7 @@
             IndexBound zStartBound = new IndexBound(row(latLonIndexRowType, queryLat, queryLon),
                                                     new SetColumnSelector(0, 1));
             IndexKeyRange zStartRange = IndexKeyRange.around(latLonIndexRowType, zStartBound);
-            Operator plan = indexScan_Default(latLonIndexRowType, false, zStartRange);
+            Operator plan = indexScan_Default(latLonIndexRowType, zStartRange, lookaheadQuantum());
             Cursor cursor = API.cursor(plan, queryContext, queryBindings);
             cursor.openTopLevel();
             Row row;
@@ -558,7 +562,7 @@
                     new IndexBound(row(beforeLatLonIndexRowType, before,  queryLat, queryLon),
                                    new SetColumnSelector(0, 1, 2));
                 IndexKeyRange zStartRange = IndexKeyRange.around(beforeLatLonIndexRowType, zStartBound);
-                Operator plan = indexScan_Default(beforeLatLonIndexRowType, false, zStartRange);
+                Operator plan = indexScan_Default(beforeLatLonIndexRowType, zStartRange, lookaheadQuantum());
                 Cursor cursor = API.cursor(plan, queryContext, queryBindings);
                 cursor.openTopLevel();
                 Row row;
@@ -700,7 +704,7 @@
         IndexBound upperRight = new IndexBound(row(latLonIndexRowType, latHi, lonHi),
                                                new SetColumnSelector(0, 1));
         IndexKeyRange box = IndexKeyRange.spatial(latLonIndexRowType, lowerLeft, upperRight);
-        Operator plan = indexScan_Default(latLonIndexRowType, false, box);
+        Operator plan = indexScan_Default(latLonIndexRowType, box, lookaheadQuantum());
         Cursor cursor = API.cursor(plan, queryContext, queryBindings);
         cursor.openTopLevel();
         Row row;
@@ -745,7 +749,7 @@
         IndexBound upperRight = new IndexBound(row(latLonIndexRowType, latHi, lonHi),
                                                new SetColumnSelector(0, 1));
         IndexKeyRange box = IndexKeyRange.spatial(latLonIndexRowType, lowerLeft, upperRight);
-        Operator plan = indexScan_Default(latLonIndexRowType, false, box);
+        Operator plan = indexScan_Default(latLonIndexRowType, box, lookaheadQuantum());
         Cursor cursor = API.cursor(plan, queryContext, queryBindings);
         cursor.openTopLevel();
         Row row;
 
=== added file 'src/test/java/com/akiban/server/test/it/qp/SpatialLatLonTableIndexScanLookaheadIT.java'
--- src/test/java/com/akiban/server/test/it/qp/SpatialLatLonTableIndexScanLookaheadIT.java	1970-01-01 00:00:00 +0000
+++ src/test/java/com/akiban/server/test/it/qp/SpatialLatLonTableIndexScanLookaheadIT.java	2013-07-18 20:08:26 +0000
@@ -0,0 +1,26 @@
+/**
+ * Copyright (C) 2009-2013 Akiban Technologies, Inc.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+package com.akiban.server.test.it.qp;
+
+public class SpatialLatLonTableIndexScanLookaheadIT extends SpatialLatLonTableIndexScanIT 
+{
+    @Override
+    protected int lookaheadQuantum() {
+        return 10;
+    }
+}