Github user QiangCai commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1841#discussion_r162932133
--- Diff:
streaming/src/main/scala/org/apache/carbondata/streaming/StreamHandoffRDD.scala
---
@@ -99,6 +101,38 @@ class StreamHandoffRDD[K, V](
formatter.format(new Date())
}
+ private def setTempDirLocation(split: Partition) : Unit = {
--- End diff --
Better to reuse this code for CarbonMergerRDD , SparkPartitionLoader ,
AlterTableLoadPartitionRDD, DataLoadProcessorStepOnSpark and CarbonFileFormat
---