乌野
乌野_个人页
乌野
文章
0
问答
2
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
暂无更多信息
-
提交了问题
2018-12-17
RichAllWindowFunction的open方法在什么时候被触发
-
回答了问题
2019-07-17
自定义AllWindowFunction类数字
借楼问下, open方法在什么时候被调用?RichAllWindowFunction 方法在apply应该怎样被是使用? 'var filteredstream = inputStream .flatMap(buildHbaseMsg(_)) .filter(b => b.actType match { case 0|1|2|3 => true case _ => false }) .countWindowAll(2L).apply(new CustomWindowFunction ())' 这样吗? {stream.apply((window, input, out: Collector[Unit]) => new CustomWindowFunction ().apply(window, input, out))} 这样调用并不会触发open方法 应该怎么使用自定义的function类赞0 踩0 评论0
滑动查看更多
暂无更多信息