[ https://issues.apache.org/jira/browse/FLINK-4693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15829595#comment-15829595 ]
ASF GitHub Bot commented on FLINK-4693: --------------------------------------- Github user fhueske commented on a diff in the pull request: https://github.com/apache/flink/pull/3150#discussion_r96810423 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetWindowAggregate.scala --- @@ -218,6 +216,85 @@ class DataSetWindowAggregate( } } + private[this] def createEventTimeSessionWindowDataSet( + inputDS: DataSet[Any], + isParserCaseSensitive: Boolean): DataSet[Any] = { + + val groupingKeys = grouping.indices.toArray + val rowTypeInfo = resultRowTypeInfo + + // grouping window + if (groupingKeys.length > 0) { + //create mapFunction for initializing the aggregations + val mapFunction = createDataSetWindowPrepareMapFunction( + window, + namedAggregates, + grouping, + inputType,isParserCaseSensitive) --- End diff -- wrap last argument as well > Add session group-windows for batch tables > ------------------------------------------- > > Key: FLINK-4693 > URL: https://issues.apache.org/jira/browse/FLINK-4693 > Project: Flink > Issue Type: Sub-task > Components: Table API & SQL > Reporter: Timo Walther > Assignee: sunjincheng > > Add Session group-windows for batch tables as described in > [FLIP-11|https://cwiki.apache.org/confluence/display/FLINK/FLIP-11%3A+Table+API+Stream+Aggregations]. > -- This message was sent by Atlassian JIRA (v6.3.4#6332)