阿里云
>
apache
>
apacheflink加入
apacheflink加入
Apache Flink：不会触发流加入窗口
我正在尝试加入apache flink中的两个流来获得一些结果。 我的项目的当前状态是，我正在获取Twitter数据并将其映射到2元组，其中保存用户的语言和定义的时间窗口中的推文总和。我根据每种语言的推文数量和每种语言的转发数量来做这些。tweet / retweet聚合在其他进程中工作正常。 我现在想要在一个时间窗口中获得转推数量的百分比到所有推文的数量。 因此我使用以下代码： Time wi...
在apache flink中拆分和加入流
"我想我有一个相当不规范的用例。我想使用以下filter函数将源流分割为多个流： val dataStream:DataStream[MyEvent] = ...val s1 = dataStream.filter(...).map(...)val s2 = dataStream.filter(...).map(...)我还有一个时间戳提取器（传入的事件将在XML中附加一个时间戳）： env.s...
1
apache更多"flink"相关
.
apacheflink生成
.
apacheflink连接
.
apacheflink时间
.
找不到apacheflink
.
apacheflink计算
.
为什么apacheflink
.
apacheflink版本
您可能感兴趣
.
apache问题
.
安装apache
.
apache虚拟机
.
apache服务器配置
.
apache配置服务
.
apache主机
.
启动apache
.
apache报错
