Port ScanFilterAndProjectOperator to WorkProcessorSourceOperator

trinodb · Jun 13, 2019 · ae7b971 · ae7b971
1 parent 549f6ac
commit ae7b971
Show file tree

Hide file tree

Showing 4 changed files with 360 additions and 147 deletions.
diff --git a/presto-hive/src/test/java/io/prestosql/plugin/hive/TestOrcPageSourceMemoryTracking.java b/presto-hive/src/test/java/io/prestosql/plugin/hive/TestOrcPageSourceMemoryTracking.java
@@ -527,6 +527,7 @@ public SourceOperator newScanFilterAndProjectOperator(DriverContext driverContex
                     0);
             SourceOperator operator = sourceOperatorFactory.createOperator(driverContext);
             operator.addSplit(new Split(new CatalogName("test"), TestingSplit.createLocalSplit(), Lifespan.taskWide()));
+            operator.noMoreSplits();
             return operator;
         }