carbondata-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ravipesala <...@git.apache.org>
Subject [GitHub] carbondata pull request #1626: [CARBONDATA-1519][PreAgg-Timeseries] Support ...
Date Wed, 06 Dec 2017 16:16:17 GMT
Github user ravipesala commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1626#discussion_r155283460
  
    --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonPreAggregateRules.scala
---
    @@ -725,6 +786,31 @@ case class CarbonPreAggregateQueryRules(sparkSession: SparkSession)
extends Rule
             Alias(aggExp,
               name)(NamedExpression.newExprId,
               alias.qualifier).asInstanceOf[NamedExpression]
    +      case alias@Alias(expression: Expression, name) =>
    +        val updatedExp =
    +          if (expression.isInstanceOf[ScalaUDF] &&
    +              expression.asInstanceOf[ScalaUDF].function.getClass.getName.equalsIgnoreCase(
    +                "org.apache.spark.sql.execution.command.timeseries.TimeseriesUDf")) {
    +          expression.asInstanceOf[ScalaUDF].transform {
    +            case attr: AttributeReference =>
    +            val childAttributeReference = getChildAttributeReference(aggDataMapSchema,
    +              attr,
    +              attributes,
    +              timeseriesFunction =
    --- End diff --
    
    remove it


---

Mime
View raw message