From 88bb05194b023467d590ac747ec5fa14d04249f5 Mon Sep 17 00:00:00 2001 From: Jacques Nadeau Date: Sat, 18 Apr 2015 16:40:02 -0700 Subject: 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 --- .../org/apache/drill/exec/physical/impl/MergingReceiverCreator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/MergingReceiverCreator.java') 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 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 children) throws ExecutionSetupException, OutOfMemoryException { -- cgit v1.2.3