Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2423#discussion_r199315149
--- Diff:
datamap/mv/core/src/main/scala/org/apache/carbondata/mv/datamap/MVAnalyzerRule.scala
---
@@ -75,6 +77,13 @@ class MVAnalyzerRule(sparkSession: SparkSession) extends
Rule[LogicalPlan] {
plan
}
} else {
+ if (catalog != null && (plan.isInstanceOf[InsertIntoCarbonTable]
+ || plan.isInstanceOf[CarbonLoadDataCommand])) {
+ val allSchema =
catalog.asInstanceOf[SummaryDatasetCatalog].listAllSchema()
+ for (schema <- allSchema) {
--- End diff --
use `foreach` instead of `for` which is faster in Scala
---