carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jack...@apache.org
Subject [1/2] incubator-carbondata git commit: Fixed select query with expression issue
Date Fri, 13 Jan 2017 09:03:06 GMT
Repository: incubator-carbondata
Updated Branches:
  refs/heads/master e547fd00a -> 8f6ae29c8


Fixed select query with expression issue

Fixed comment


Project: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/commit/559cac4c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/tree/559cac4c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-carbondata/diff/559cac4c

Branch: refs/heads/master
Commit: 559cac4cb7b116656dba85af49131e18ceacb80c
Parents: e547fd0
Author: ravipesala <ravi.pesala@gmail.com>
Authored: Thu Jan 12 20:25:25 2017 +0530
Committer: jackylk <jacky.likun@huawei.com>
Committed: Fri Jan 13 17:02:25 2017 +0800

----------------------------------------------------------------------
 .../main/scala/org/apache/spark/sql/CarbonDictionaryDecoder.scala | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-carbondata/blob/559cac4c/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDictionaryDecoder.scala
----------------------------------------------------------------------
diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDictionaryDecoder.scala
b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDictionaryDecoder.scala
index fbcfbc8..10454d6 100644
--- a/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDictionaryDecoder.scala
+++ b/integration/spark2/src/main/scala/org/apache/spark/sql/CarbonDictionaryDecoder.scala
@@ -237,6 +237,8 @@ class CarbonDecoderRDD(
     output: Seq[Attribute])
     extends RDD[InternalRow](prev) {
 
+  private val storepath = CarbonEnv.get.carbonMetastore.storePath
+
   def canBeDecoded(attr: Attribute): Boolean = {
     profile match {
       case ip: IncludeProfile if ip.attributes.nonEmpty =>
@@ -302,7 +304,6 @@ class CarbonDecoderRDD(
   }
 
   override def compute(split: Partition, context: TaskContext): Iterator[InternalRow] = {
-          val storepath = CarbonEnv.get.carbonMetastore.storePath
     val absoluteTableIdentifiers = relations.map { relation =>
       val carbonTable = relation.carbonRelation.carbonRelation.metaData.carbonTable
       (carbonTable.getFactTableName, carbonTable.getAbsoluteTableIdentifier)


Mime
View raw message