我们知道,一个Flink程序一般有下面几个核心步骤。

①设置执行环境。

②读取一到多个数据源。

③根据业务逻辑对数据流进行转换。

④将结果输出到Sink。

⑤调用作业执行函数。

results matching ""

    No results matching ""