DataStream

Flink DataStream API

1.  API基本概念Flink程序可以对分布式集合进行转换（例如： filtering, mapping, updating state, joining, grouping, defining windows, aggregating）集合最初是从源创建的

DataStream API（一）

DataStream API（一）在了解DataStream API之前我们先来了解一下Flink API的构成。Flink API是分层的。由最底层的Stateful Stream Process到最顶层的SQL分为四层。如下图：DataStream API

如何掌握Table与DataStream之间的互转