Data Lake for Enterprises

DataStream API

As the name says it all, the DataStream API in Flink can be used to do any operation on the stream of the inflowing data. The operation is one on each element in a stream or stream windows as the case may be. It offers many built-in transformations and also gives a toolbox to create custom ones if needed for your use case. DataStream is the core structure in the DataStream API.

Flink’s DataStream API is capable of handling almost any kind of data types (basic types such as string arrays, and so on, and composite types such as tuples, POJO’s, and so on).

The following figure shows DataStream program execution in Flink:

Figure ...