diff options
author | Timothy Farkas <timothyfarkas@apache.org> | 2018-06-04 10:45:12 -0700 |
---|---|---|
committer | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2018-08-27 10:14:39 +0300 |
commit | d8f9fb6a5cf22a01fa3f48bd40e7dbeb3cb6e4e4 (patch) | |
tree | 31297c5011b1fa9c476aa070d2fd56cc47486901 /exec/vector | |
parent | e9ffb5bde37efad9f0b646773311f23ea2dbda5d (diff) |
DRILL-6461: Added basic data correctness tests for hash agg, and improved operator unit testing framework.
git closes #1344
Diffstat (limited to 'exec/vector')
-rw-r--r-- | exec/vector/src/main/codegen/templates/FixedValueVectors.java | 2 | ||||
-rw-r--r-- | exec/vector/src/main/codegen/templates/NullableValueVectors.java | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/exec/vector/src/main/codegen/templates/FixedValueVectors.java b/exec/vector/src/main/codegen/templates/FixedValueVectors.java index eb413b045..a98aa66b6 100644 --- a/exec/vector/src/main/codegen/templates/FixedValueVectors.java +++ b/exec/vector/src/main/codegen/templates/FixedValueVectors.java @@ -358,7 +358,7 @@ public final class ${minor.class}Vector extends BaseDataValueVector implements F @Override public void copyEntry(int toIndex, ValueVector from, int fromIndex) { - ((${minor.class}Vector) from).data.getBytes(fromIndex * VALUE_WIDTH, data, toIndex * VALUE_WIDTH, VALUE_WIDTH); + copyFromSafe(fromIndex, toIndex, (${minor.class}Vector) from); } public void decrementAllocationMonitor() { diff --git a/exec/vector/src/main/codegen/templates/NullableValueVectors.java b/exec/vector/src/main/codegen/templates/NullableValueVectors.java index ff066fbc9..f82c71896 100644 --- a/exec/vector/src/main/codegen/templates/NullableValueVectors.java +++ b/exec/vector/src/main/codegen/templates/NullableValueVectors.java @@ -433,7 +433,7 @@ public final class ${className} extends BaseDataValueVector implements <#if type // Handle the case of not-nullable copied into a nullable if (from instanceof ${minor.class}Vector) { - bits.getMutator().set(toIndex,1); + bits.getMutator().setSafe(toIndex,1); values.copyFromSafe(fromIndex,toIndex,(${minor.class}Vector)from); return; } |