tajo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hyun...@apache.org
Subject [1/2] TAJO-583: Broadcast join does not work on partitioned tables.
Date Fri, 07 Feb 2014 07:32:50 GMT
Updated Branches:
  refs/heads/master 009e0253c -> 4179a7c92


http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/4179a7c9/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testNoProjectionJoinQual.result
----------------------------------------------------------------------
diff --git a/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testNoProjectionJoinQual.result
b/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testNoProjectionJoinQual.result
new file mode 100644
index 0000000..19336a7
--- /dev/null
+++ b/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testNoProjectionJoinQual.result
@@ -0,0 +1,3 @@
+?count
+-------------------------------
+5
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/4179a7c9/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testPartialFilterPushDown.result
----------------------------------------------------------------------
diff --git a/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testPartialFilterPushDown.result
b/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testPartialFilterPushDown.result
new file mode 100644
index 0000000..f3fc0d3
--- /dev/null
+++ b/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testPartialFilterPushDown.result
@@ -0,0 +1,3 @@
+c_name,?count_1
+-------------------------------
+CUSTOMER#000000003,1
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/4179a7c9/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testPartitionTableJoinSmallTable.result
----------------------------------------------------------------------
diff --git a/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testPartitionTableJoinSmallTable.result
b/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testPartitionTableJoinSmallTable.result
new file mode 100644
index 0000000..f28f634
--- /dev/null
+++ b/tajo-core/tajo-core-backend/src/test/resources/results/TestJoinOnPartitionedTables/testPartitionTableJoinSmallTable.result
@@ -0,0 +1,7 @@
+c_custkey,c_name,c_nationkey,n_nationkey
+-------------------------------
+1,Customer#000000001,15,15
+2,Customer#000000002,13,13
+3,Customer#000000003,1,1
+4,Customer#000000004,4,4
+5,Customer#000000005,3,3
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/4179a7c9/tajo-core/tajo-core-backend/src/test/resources/results/TestTablePartitions/case3.result
----------------------------------------------------------------------
diff --git a/tajo-core/tajo-core-backend/src/test/resources/results/TestTablePartitions/case3.result
b/tajo-core/tajo-core-backend/src/test/resources/results/TestTablePartitions/case3.result
new file mode 100644
index 0000000..ef8c512
--- /dev/null
+++ b/tajo-core/tajo-core-backend/src/test/resources/results/TestTablePartitions/case3.result
@@ -0,0 +1,5 @@
+l_orderkey,col1,key
+-------------------------------
+2,2,38.0
+3,3,45.0
+3,3,45.0
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-tajo/blob/4179a7c9/tajo-storage/src/main/java/org/apache/tajo/storage/CSVFile.java
----------------------------------------------------------------------
diff --git a/tajo-storage/src/main/java/org/apache/tajo/storage/CSVFile.java b/tajo-storage/src/main/java/org/apache/tajo/storage/CSVFile.java
index 5d05d6f..490787f 100644
--- a/tajo-storage/src/main/java/org/apache/tajo/storage/CSVFile.java
+++ b/tajo-storage/src/main/java/org/apache/tajo/storage/CSVFile.java
@@ -325,7 +325,7 @@ public class CSVFile {
 
       targetColumnIndexes = new int[targets.length];
       for (int i = 0; i < targets.length; i++) {
-        targetColumnIndexes[i] = schema.getColumnIdByName(targets[i].getColumnName());
+        targetColumnIndexes[i] = schema.getColumnId(targets[i].getQualifiedName());
       }
 
       try {


Mime
View raw message