2019-07-02我期望是基于spark或flink讲解的重实践思想，轻知识，这个可以自己下去学 4- 2019-11-14TestClass 里的这个 PCollection<String> output = input.apply(ParDo.of(new EvenNumberFn())); 里面的泛型是不是写错了？偶数是 Integer 吧？
2019-09-10看来我得先去学学Java了，不会java，看不太懂。
2019-07-08Beam 有类似sparksql的api吗？作者回复: 谢谢你的提问！有Beam SQL，不过现在只支持Java。
2019-06-30我觉得测试的话，相对麻烦的地方还是在工程脚手架的设计上。
显然代码本身要抽象封装好，确保测试能覆盖生产代码，而不是生产代码的“拷贝”。
但有些在代码之外的问题让我挺好奇的：
如何保证测试数据的格式和生产数据的格式同步？
流处理的测试怎么模拟时间？
团队是如何在流程上确保pipeline必须经过测试才能运行的，是通过CI/CD来自动执行pipeline？还是往往通过人力把关？展开