Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1626#discussion_r155276423
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateListeners.scala
---
@@ -51,8 +63,26 @@ object LoadPostAggregateListener extends
OperationEventListener {
carbonLoadModel.getTableName, "false")
val childTableName =
dataMapSchema.getRelationIdentifier.getTableName
val childDatabaseName =
dataMapSchema.getRelationIdentifier.getDatabaseName
- val childDataFrame = sparkSession.sql(new
CarbonSpark2SqlParser().addPreAggLoadFunction(
- s"${ dataMapSchema.getProperties.get("CHILD_SELECT QUERY") }
")).drop("preAggLoad")
+ val childDataFrame =
+ if
(!dataMapSchema.asInstanceOf[AggregationDataMapSchema].isTimeseriesDataMap) {
--- End diff --
no need to use asInstanceOf
---
