- 主题:请教一个flink的问题
每个window结束sink一次
【 在 guestking 的大作中提到: 】
: flink设置了window之后，是每个window结束的时候才调用一次sink？
: 还是有办法每个数据过来之后都sink一下
--
FROM 124.202.207.*
窗口就是你收集数据的时间区间，没有结束会一直收集，不会sink
【 在 guestking 的大作中提到: 】
: 那在这个window结束之前，结果就不可见了？
: 如果我一个window是一天的话，那岂不是要一天结束了才能知道统计结果
:
--
FROM 124.202.207.*
主线程和sink在不同线程，你可以试试在main函数设置一个其他类的静态变量，在sink里是取不到的
【 在 guestking 的大作中提到: 】
: 想了想，应该是同步的
: 要做成异步的，估计还得借助外部队列之类的东西来搞
:
--
FROM 124.202.207.*