W.T
2019-07-19
老师讲的很好!要是能提供一个完整的案例,包括测试数据和运行时,不需要读者折腾太多,下载下来直接就能运行,相信会引起更多的共鸣,将这个专栏衬托得更加精彩!
1
2
时光机器
2020-01-12
感觉这个例子没有提现出流式计算的实时特性呀。老师能举个像阿里实时战报看板这样高实时性要求的例子吗,感谢感谢
Cool
2019-09-26
觉得这些例子逻辑上还是相对来说比较简单, 流式处理当输入源是多个的时候, 比如对于交易所来说 一个是实时 trade, 一个是实时的 price,都使用相同的 fix_window, join 起来之后,再做计算输出等等
Cool
2019-09-26
蔡老师, 对于流处理需要对pipeline中的数据,进行数据补充时,可以使用 sideinput, 但是我看了官方文档,只能是静态的metadata,然后再Pardo中加到每一条数据, 并不能动态更新这个sideinput(比如在数据库中动态查询), 请问这种情况能怎么解决?
李孟
2019-07-24
老师我想问下, PCollection<String>这个种懒加载出来的集合怎么转存成临时的list集合?
我们在线,来聊聊吧
✕
您好,当前有专业客服人员在线,让我们来帮助您吧。
我们在线,来聊聊吧