You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@carbondata.apache.org by jackylk <gi...@git.apache.org> on 2018/07/04 06:29:11 UTC

[GitHub] carbondata pull request #2432: [CARBONDATA-2675][32K] Support config long_st...

Github user jackylk commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2432#discussion_r200019284
  
    --- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/preaaggregate/PreAggregateTableHelper.scala ---
    @@ -106,6 +106,24 @@ case class PreAggregateTableHelper(
         tableProperties.put(CarbonCommonConstants.FLAT_FOLDER,
           parentTable.getTableInfo.getFactTable.getTableProperties.asScala.getOrElse(
             CarbonCommonConstants.FLAT_FOLDER, CarbonCommonConstants.DEFAULT_FLAT_FOLDER))
    +
    +    // update column name with prefix for long_string_column
    +    val longStringColumn = tableProperties.get(CarbonCommonConstants.LONG_STRING_COLUMNS)
    +    if (longStringColumn != None) {
    +      val fieldNames = fields.map(_.column)
    +      val newLongStringColumn = longStringColumn.get.split(",").map(_.trim).map(colName => {
    --- End diff --
    
    change format to
    ```
    .map { colName =>
       xxx
    }
    ```


---