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

Reply via email to