You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ch...@apache.org on 2016/08/30 07:20:04 UTC
[1/2] incubator-carbondata git commit: When splits is null,
no need to return null CarbonSparkPartition
Repository: incubator-carbondata
Updated Branches:
refs/heads/master 9bd37eae8 -> b5b0bad14
When splits is null, no need to return null CarbonSparkPartition
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/a561cebb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/a561cebb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/a561cebb
Branch: refs/heads/master
Commit: a561cebbfb7a2f493621c236d8237155a8ec15dc
Parents: 9bd37ea
Author: foryou2030 <fo...@126.com>
Authored: Sat Aug 27 18:05:38 2016 +0800
Committer: chenliang613 <ch...@apache.org>
Committed: Tue Aug 30 15:19:07 2016 +0800
----------------------------------------------------------------------
.../scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala | 4 ----
1 file changed, 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/a561cebb/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
----------------------------------------------------------------------
diff --git a/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala b/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
index 6c0438f..65b55c7 100644
--- a/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
+++ b/integration/spark/src/main/scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala
@@ -157,14 +157,10 @@ class CarbonScanRDD[V: ClassTag](
}
} else {
logInfo("No blocks identified to scan")
- val nodesPerBlock = new util.ArrayList[TableBlockInfo]()
- result.add(new CarbonSparkPartition(id, 0, Seq("").toArray, nodesPerBlock))
}
}
else {
logInfo("No valid segments found to scan")
- val nodesPerBlock = new util.ArrayList[TableBlockInfo]()
- result.add(new CarbonSparkPartition(id, 0, Seq("").toArray, nodesPerBlock))
}
result.toArray(new Array[Partition](result.size()))
}
[2/2] incubator-carbondata git commit: When query result is null,
getPartitions function should return empty Arrary[Partition] This
closes #101
Posted by ch...@apache.org.
When query result is null, getPartitions function should return empty Arrary[Partition] This closes #101
Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/b5b0bad1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/b5b0bad1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/b5b0bad1
Branch: refs/heads/master
Commit: b5b0bad14b99bf7a091b3e320a3bdb4c00ee0bce
Parents: 9bd37ea a561ceb
Author: chenliang613 <ch...@apache.org>
Authored: Tue Aug 30 15:19:46 2016 +0800
Committer: chenliang613 <ch...@apache.org>
Committed: Tue Aug 30 15:19:46 2016 +0800
----------------------------------------------------------------------
.../scala/org/apache/carbondata/spark/rdd/CarbonScanRDD.scala | 4 ----
1 file changed, 4 deletions(-)
----------------------------------------------------------------------