Flink DataStream转换操做大集合

Flink DataStream转换操做 1.Single-DataStream操做 1.Map[DataStream -> DataStream] 调用用户定义的MapFunction对DataStream[T]数据进行处理，造成新的DataStream[T]，其中数据格式可能会发生变化,经常使用做对数据集内数据的清洗和转换。 import org.apache.flink.api.common

>>阅读原文<<