dianfu commented on a change in pull request #7209: [FLINK-10977][table] Add UnBounded FlatAggregate operator to streaming Table API URL: https://github.com/apache/flink/pull/7209#discussion_r242013108
########## File path: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/table.scala ########## @@ -1028,6 +1061,119 @@ class Table( } } +class FlatAggTable( Review comment: Can you describe when FlatAggTable may be needed? I'm fine to keep it if you're definitely sure it will be added back in the future. Otherwise I would suggest to remove it and only add it when necessary. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
