Updated Branches: refs/heads/master 6e39efc4b -> 9f69ed05b
Add fix so RecordBatchLoader correctly offsets vectors within record batches. Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/a1cdca51 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/a1cdca51 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/a1cdca51 Branch: refs/heads/master Commit: a1cdca51109d96cef57b87d2130fefe8b798aea7 Parents: 6e39efc Author: Jacques Nadeau <[email protected]> Authored: Sat Jul 27 10:16:05 2013 -0700 Committer: Jacques Nadeau <[email protected]> Committed: Sat Jul 27 10:16:05 2013 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/drill/exec/record/RecordBatchLoader.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a1cdca51/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordBatchLoader.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordBatchLoader.java b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordBatchLoader.java index 4a12af6..ebacd6e 100644 --- a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordBatchLoader.java +++ b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/record/RecordBatchLoader.java @@ -88,6 +88,7 @@ public class RecordBatchLoader implements Iterable<ValueVector>{ MaterializedField m = new MaterializedField(fieldDef); v = TypeHelper.getNewVector(m, allocator); v.load(fmd, buf.slice(bufOffset, fmd.getBufferLength())); + bufOffset += fmd.getBufferLength(); newVectors.add(v); }
