Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1613#discussion_r154977627
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateUtil.scala
---
@@ -493,4 +495,49 @@ object PreAggregateUtil {
updatedPlan
}
+ /**
+ * This method will start load process on the data map
+ */
+ def startDataLoadForDataMap(parentCarbonTable: CarbonTable,
+ dataMapIdentifier: TableIdentifier,
+ queryString: String,
+ segmentToLoad: String,
+ validateSegments: Boolean,
+ sparkSession: SparkSession): Unit = {
+ CarbonSession.threadSet(
--- End diff --
Do not use thread local to pass parameters, pass them explicitly to the
command
---
