因为sink到hbase,使用一个column存了top5的list,sink前我要组合一下这个list
> 在 2019年8月28日,10:12,Jark Wu <imj...@gmail.com> 写道: > > 为什么还需要后面接 process operator 呢? Flink TopN 已经帮你维护好了 state,直接输出到一个 update sink > 中就可以了。 > > > Best, > Jark > >> 在 2019年8月28日,10:08,ddwcg <3149768...@qq.com> 写道: >> >> process >