Flink（二）--DataStream的各種算子

本文用java代碼介紹flink的各種算子。採用上篇文章中對接的kafka數據源。java 1、Map：對數據進行逐個遍歷，經常使用做對數據集內數據的清洗和轉換dom input.print(); SingleOutputStreamOperator<Tuple2<String, Integer>> map = input.map(new MapFunction<String, Tuple

>>阅读原文<<