Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1467#discussion_r149281818
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/AlterTableCompactionCommand.scala
---
@@ -87,4 +94,113 @@ case class AlterTableCompactionCommand(
}
Seq.empty
}
+
+ private def alterTableForCompaction(sqlContext: SQLContext,
+ alterTableModel: AlterTableModel,
+ carbonLoadModel: CarbonLoadModel,
+ storeLocation: String): Unit = {
+ var compactionSize: Long = 0
+ var compactionType: CompactionType = CompactionType.MINOR_COMPACTION
+ if (alterTableModel.compactionType.equalsIgnoreCase("major")) {
+ compactionSize =
CarbonDataMergerUtil.getCompactionSize(CompactionType.MAJOR_COMPACTION)
+ compactionType = CompactionType.MAJOR_COMPACTION
+ } else if (alterTableModel.compactionType
+
.equalsIgnoreCase(CompactionType.IUD_UPDDEL_DELTA_COMPACTION.toString)) {
+ compactionType = CompactionType.IUD_UPDDEL_DELTA_COMPACTION
+ if (alterTableModel.segmentUpdateStatusManager.get != None) {
+ carbonLoadModel
+
.setSegmentUpdateStatusManager(alterTableModel.segmentUpdateStatusManager.get)
+
+ carbonLoadModel
--- End diff --
fixed
---
