本文主要是介绍如何使用 DataStream API 来处理数据？，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
在 3.3 节中讲了数据转换常用的 Operators（算子），然后在 3.2 节中也讲了 Flink 中窗口的概念和原理，那么我们这篇文章再来细讲一下 Flink 中的各种 DataStream API。
我们先来看下源码里面的 DataStream 大概有哪些类呢？
可以发现其实还是有很多的类，只有熟练掌握了这些 API，我们才能在做数据转换和计算的时候足够灵活的运用开来（知道何时该选用哪种 DataStream？选用哪个 Function？）。那么我们先从 DataStream 开始吧！
DataStream 如何使用及分析
首先我们来看下 DataStream 这个类的定义吧：
A DataStream represents a stream of elements of the same type. A DataStreamcan be transformed into another DataStream by applying a transformation asDataStream#map or DataStream#filter}
大概意思是：DataStream 表示相同类型的元素组成的数据流，一个数据流可以通过 map/filter 等算子转换成另一个数据流。
然后 DataStream 的类结构图如下：
它的继承类有 KeyedStr
这篇关于如何使用 DataStream API 来处理数据？的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
