说明

1. 获取执行环境
2. 定义source，读取数据
3. 定义 Transformation（转换）操作，如：分组统计单词出现次数
4. 定义 sink，如：将结果保存到数据库
5. 执行

原文出处：/show_1IX429bexc2F.html