你好，我是蔡元楠。 今天我要与你分享的主题是“Amazon热销榜Beam Pipeline实战”。 两个月前，亚马逊（Amazon）宣布将关闭中国国内电商业务的消息你一定还记忆犹新。虽然亚马逊遗憾离场，但它依然是目前全球市值最高的电商公司。 作为美国...

你好，我是蔡元楠。 今天我要与你分享的主题是“横看成岭侧成峰：再战Streaming WordCount”。 在上一讲中，我们学习了Beam窗口（Window）的概念。当时，我们提到窗口技术的产生是因为我们想要根据时间戳去分组处理一个PCollect...

你好，我是蔡元楠。 今天我要与你分享的主题是“Beam Window：打通流处理的任督二脉”。 在上一讲中，我们一起用Beam编写了第一个完整的WordCount项目，我们所用的例子是统计莎士比亚的文集中最常使用到的一些单词。 这里我们所用到的“莎士...

你好，我是蔡元楠。 今天我要与你分享的主题是“WordCount Beam Pipeline实战”。 前面我们已经学习了Beam的基础数据结构PCollection，基本数据转换操作Transform，还有Pipeline等技术。你一定跃跃欲试，想要...

你好，我是蔡元楠。 今天我要与你分享的主题是“Apache Beam实战冲刺：Beam如何run everywhere”。 你可能已经注意到，自第26讲到第29讲，从Pipeline的输入输出，到Pipeline的设计，再到Pipeline的测试，B...

你好，我是蔡元楠。 今天我要与你分享的主题是“如何测试Beam Pipeline”。 在上一讲中，我们结合了第7讲的内容，一起学习了在Beam的世界中我们该怎么设计好对应的设计模式。而在今天这一讲中，我想要讲讲在日常开发中经常会被忽略的，但是又非常重...