You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ja...@apache.org on 2014/05/23 04:23:26 UTC
[2/3] git commit: DRILL-796: Selecting * from HBase tables filtered
with 'row_key' returns empty arrays
DRILL-796: Selecting * from HBase tables filtered with 'row_key' returns empty arrays
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/84390e8f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/84390e8f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/84390e8f
Branch: refs/heads/master
Commit: 84390e8f0f692138b97fc2cbdd1570eddf7f3081
Parents: 46a0503
Author: Aditya Kishore <ad...@maprtech.com>
Authored: Wed May 21 20:34:55 2014 -0700
Committer: Jacques Nadeau <ja...@apache.org>
Committed: Thu May 22 18:49:26 2014 -0700
----------------------------------------------------------------------
.../main/java/org/apache/drill/exec/vector/complex/MapVector.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/84390e8f/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java
----------------------------------------------------------------------
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java b/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java
index 9b2e119..51aec06 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/vector/complex/MapVector.java
@@ -273,6 +273,7 @@ public class MapVector extends AbstractContainerVector {
@Override
public void load(SerializedField metadata, ByteBuf buf) {
List<SerializedField> fields = metadata.getChildList();
+ valueCount = metadata.getValueCount();
int bufOffset = 0;
for (SerializedField fmd : fields) {
@@ -381,6 +382,7 @@ public class MapVector extends AbstractContainerVector {
@Override
public void clear() {
+ valueCount = 0;
for(ValueVector v : vectors.values()){
v.clear();;
}