Repository: drill Updated Branches: refs/heads/master 3e3388095 -> b6a387878
DRILL-2079: Use AllocationHelper to allocate memory for vectors. Project: http://git-wip-us.apache.org/repos/asf/drill/repo Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/b6a38787 Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/b6a38787 Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/b6a38787 Branch: refs/heads/master Commit: b6a3878784698cd58015050b29ecc123c841ad5e Parents: 4976fb9 Author: Mehant Baid <meha...@gmail.com> Authored: Mon Jan 26 19:13:18 2015 -0800 Committer: Mehant Baid <meha...@gmail.com> Committed: Mon Jan 26 22:00:31 2015 -0800 ---------------------------------------------------------------------- .../exec/physical/impl/xsort/PriorityQueueCopierTemplate.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/drill/blob/b6a38787/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/xsort/PriorityQueueCopierTemplate.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/xsort/PriorityQueueCopierTemplate.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/xsort/PriorityQueueCopierTemplate.java index 17565ed..fe67064 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/xsort/PriorityQueueCopierTemplate.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/xsort/PriorityQueueCopierTemplate.java @@ -27,6 +27,7 @@ import org.apache.drill.exec.ops.FragmentContext; import org.apache.drill.exec.record.VectorAccessible; import org.apache.drill.exec.record.VectorWrapper; import org.apache.drill.exec.record.selection.SelectionVector4; +import org.apache.drill.exec.vector.AllocationHelper; public abstract class PriorityQueueCopierTemplate implements PriorityQueueCopier { static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(PriorityQueueCopierTemplate.class); @@ -123,7 +124,7 @@ public abstract class PriorityQueueCopierTemplate implements PriorityQueueCopier private void allocateVectors(int targetRecordCount) { for (VectorWrapper w: outgoing) { - w.getValueVector().allocateNew(); + AllocationHelper.allocateNew(w.getValueVector(), targetRecordCount); } }
