Github user kunal642 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1613#discussion_r155155362
--- 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 --
This parameter is used to specify the segments to scan in CarbonScanRDD.
Therefore i cannot pass it explicitly. As discussed with @gvramana and
@ravipesala this was only option that was agreed upon.
---
