Github user xubo245 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1865#discussion_r164416505
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/datamap/CarbonCreateDataMapCommand.scala
---
@@ -79,32 +79,27 @@ case class CarbonCreateDataMapCommand(
}
createPreAggregateTableCommands.flatMap(_.processMetadata(sparkSession))
} else {
- val dataMapSchema = new DataMapSchema(dataMapName, dmClassName)
- dataMapSchema.setProperties(new java.util.HashMap[String,
String](dmproperties.asJava))
- val dbName =
CarbonEnv.getDatabaseName(tableIdentifier.database)(sparkSession)
- // upadting the parent table about dataschema
- PreAggregateUtil.updateMainTable(dbName, tableIdentifier.table,
dataMapSchema, sparkSession)
+ throw new UnsupportedDataMapException(dmClassName)
}
LOGGER.audit(s"DataMap $dataMapName successfully added to Table ${
tableIdentifier.table }")
Seq.empty
}
override def processData(sparkSession: SparkSession): Seq[Row] = {
- if
(dmClassName.equals("org.apache.carbondata.datamap.AggregateDataMapHandler") ||
--- End diff --
We can discuss with jacky li, and raise another PR for this if it necessary
---
