PyFlink DataStream 程序骨架、常用 Source/Sink、状态(State)、与 Table/SQL 互转一篇搞定
1. PyFlink DataStream 作业的通用结构一个标准的 DataStream 作业,通常有 5 步:1)创建 StreamExecutionEnvironment
2)创建 Source 得到初始 DataStream
3)编排 transformation(map/filter/key_by/re
