[ 
https://issues.apache.org/jira/browse/FLINK-5303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15804954#comment-15804954
 ] 

ASF GitHub Bot commented on FLINK-5303:
---------------------------------------

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

    https://github.com/apache/flink/pull/2976#discussion_r94963463
  
    --- Diff: 
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateReduceGroupFunction.scala
 ---
    @@ -20,26 +20,29 @@ package org.apache.flink.table.runtime.aggregate
     import java.lang.Iterable
     
     import org.apache.flink.api.common.functions.RichGroupReduceFunction
    -import org.apache.flink.types.Row
     import org.apache.flink.configuration.Configuration
    +import org.apache.flink.types.Row
     import org.apache.flink.util.{Collector, Preconditions}
     
     import scala.collection.JavaConversions._
     
     /**
    - * It wraps the aggregate logic inside of 
    + * It wraps the aggregate logic inside of
      * [[org.apache.flink.api.java.operators.GroupReduceOperator]].
      *
    - * @param aggregates   The aggregate functions.
    - * @param groupKeysMapping The index mapping of group keys between 
intermediate aggregate Row 
    - *                         and output Row.
    - * @param aggregateMapping The index mapping between aggregate function 
list and aggregated value
    - *                         index in output Row.
    + * @param aggregates          The aggregate functions.
    + * @param groupKeysMapping    The index mapping of group keys between 
intermediate aggregate Row
    + *                            and output Row.
    + * @param aggregateMapping    The index mapping between aggregate function 
list and aggregated value
    + *                            index in output Row.
    + * @param groupingSetsMapping The index mapping of keys in grouping sets 
between intermediate
    --- End diff --
    
    It is not documented that this parameter can be null. I would recommend to 
use an `Option` here.


> Add CUBE/ROLLUP/GROUPING SETS operator in SQL
> ---------------------------------------------
>
>                 Key: FLINK-5303
>                 URL: https://issues.apache.org/jira/browse/FLINK-5303
>             Project: Flink
>          Issue Type: New Feature
>          Components: Documentation, Table API & SQL
>            Reporter: Alexander Chermenin
>            Assignee: Alexander Chermenin
>
> Add support for such operators as CUBE, ROLLUP and GROUPING SETS in SQL.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to