xintongsong commented on a change in pull request #9784: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9784#discussion_r334339338
########## File path: docs/getting-started/walkthroughs/table_api.zh.md ########## @@ -399,27 +403,29 @@ tEnv.registerTableSource("transactions", new UnboundedTransactionTableSource) </div> </div> -And that's it, a fully functional, stateful, distributed streaming application! -The query continuously consumes the stream of transactions, computes the hourly spendings, and emits results as soon as they are ready. -Since the input is unbounded, the query keeps running until it is manually stopped. -And because the Job uses time window-based aggregations, Flink can perform specific optimizations such as state clean up when the framework knows that no more records will arrive for a particular window. +这就是一个功能齐全、有状态的分布式流式应用! +这个查询会持续处理交易流,计算每小时的消费额,然后实时输出结果。 +由于输入是无界的,因此查询将一直运行,直到手动停止为止。 +因为这个作业使用了基于时间的聚合,Flink 可以使用一些特定的优化,比如当系统知道一个特定的窗口不会再有新的数据到来,它就会对状态进行清理。 Review comment: “基于时间的聚合”->“基于时间窗口的聚合”:这点很重要,如果不是基于窗口,flink无法进行此类优化 ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to 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