![]() |
1
0
我想你可以用一个跟在窗口后面的操作符来完成这项工作,它以1的并行度运行。这个操作符需要检测一批新的结果何时开始从窗口到达,并且可以做需要做的事情来关闭数据库中的前一个窗口并在此时初始化新的窗口。它还可以实现
此运算符需要保留一个托管状态,即当前窗口的某种标识符,以便它能够检测新窗口何时开始。来自窗口的结果将需要携带这个标识符——它可能只是窗口的开始或结束时间戳。
根据这些要求,这个操作员可以是
|
![]() |
Ellen Spertus · 使用Scala访问HBase的推荐方法 7 年前 |
![]() |
Daniel · 目录中的Apache Flink流文件 7 年前 |
![]() |
Jicaar · 一个卡夫卡制作人可以被多个接收器安全使用吗? 7 年前 |