DRILL-1151: Update 'lastSet' in repeated map vector while performing copy
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/d2d047ab Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/d2d047ab Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/d2d047ab Branch: refs/heads/master Commit: d2d047ab81be473d8ba2e792e0b1ec52b2763e97 Parents: a744010 Author: Mehant Baid <[email protected]> Authored: Mon Jul 28 18:45:48 2014 -0700 Committer: Aditya Kishore <[email protected]> Committed: Tue Jul 29 11:44:30 2014 -0700 ---------------------------------------------------------------------- .../org/apache/drill/exec/vector/complex/RepeatedMapVector.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/d2d047ab/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedMapVector.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedMapVector.java b/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedMapVector.java index 30f5fc7..952fb4b 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedMapVector.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/RepeatedMapVector.java @@ -65,7 +65,7 @@ public class RepeatedMapVector extends AbstractContainerVector implements Repeat private final Mutator mutator = new Mutator(); private final BufferAllocator allocator; private final MaterializedField field; - private int lastSet = 0; + private int lastSet = -1; public RepeatedMapVector(MaterializedField field, BufferAllocator allocator){ this.field = field; @@ -254,6 +254,7 @@ public class RepeatedMapVector extends AbstractContainerVector implements Repeat } } if(!this.to.offsets.getMutator().setSafe(to+1, newIndex)) return false; + this.to.lastSet++; return true; }
