carbondata-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From QiangCai <...@git.apache.org>
Subject [GitHub] carbondata pull request #1317: [CARBONDATA-1316] drop partition
Date Sat, 09 Sep 2017 02:32:02 GMT
Github user QiangCai commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/1317#discussion_r137916597
  
    --- Diff: integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/AlterTableLoadPartitionRDD.scala
---
    @@ -104,20 +103,20 @@ class AlterTableSplitPartitionRDD[K, V](
                     true
                 )
     
    -            val splitStatus = if (rows.isEmpty) {
    +            val loadStatus = if (rows.isEmpty) {
                     LOGGER.info("After repartition this split, NO target rows to write back.")
                     true
                 } else {
    +                val segmentProperties = PartitionUtils.getSegmentProperties(identifier,
    +                    segmentId, partitionIds.toList, oldPartitionIdList, partitionInfo)
    +                val processor = new RowResultProcessor(
    +                    carbonTable,
    +                    carbonLoadModel,
    +                    segmentProperties,
    +                    tempStoreLoc,
    +                    bucketId
    +                )
    --- End diff --
    
    move to last line


---

Mime
View raw message