aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
diff options
context:
space:
mode:
authorJacques Nadeau <jacques@apache.org>2015-04-18 16:40:02 -0700
committerJacques Nadeau <jacques@apache.org>2015-05-02 19:33:54 -0700
commit88bb05194b023467d590ac747ec5fa14d04249f5 (patch)
tree5be7744f49f6b22f501bc681d965c780d88b69e3 /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
parent636177df12c593368676d42bc17b65d684c8d000 (diff)
DRILL-2826: Simplify and centralize Operator Cleanup
- Remove cleanup method from RecordBatch interface - Make OperatorContext creation and closing the management of FragmentContext - Make OperatorContext an abstract class and the impl only available to FragmentContext - Make RecordBatch closing the responsibility of the RootExec - Make all closes be suppresing closes to maximize memory release in failure - Add new CloseableRecordBatch interface used by RootExec - Make RootExec AutoCloseable - Update RecordBatchCreator to return CloseableRecordBatches so that RootExec can maintain list - Generate list of operators through change in ImplCreator
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
index daef44cce..1bf6c0105 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java
@@ -32,7 +32,7 @@ public class MergingReceiverCreator implements BatchCreator<MergingReceiverPOP>
static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(MergingReceiverCreator.class);
@Override
- public RecordBatch getBatch(FragmentContext context,
+ public MergingRecordBatch getBatch(FragmentContext context,
MergingReceiverPOP receiver,
List<RecordBatch> children)
throws ExecutionSetupException, OutOfMemoryException {