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.pes...@gmail.com> Authored: Thu Jan 12 20:25:25 2017 +0530 Committer: jackylk <jacky.li...@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)
