Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2817#discussion_r226200613
--- Diff:
integration/spark-common/src/main/scala/org/apache/spark/rdd/CarbonMergeFilesRDD.scala
---
@@ -34,6 +36,59 @@ case class CarbonMergeFilePartition(rddId: Int, idx:
Int, segmentId: String)
override def hashCode(): Int = 41 * (41 + rddId) + idx
}
+object CarbonMergeFilesRDD {
+ /**
+ * Merge the carbonindex files with in the segment to carbonindexmerge
file inside same segment
+ *
+ * @param readFileFooterFromCarbonDataFile flag to read file footer
information from carbondata
+ * file. This will used in case
of upgrade from version
+ * which do not store the
blocklet info to current
+ * version
+ */
+ def mergeIndexFiles(sparkSession: SparkSession,
+ segmentIds: Seq[String],
--- End diff --
OK~
---
