Shulou(Shulou.com)06/01 Report--

This article introduces the knowledge of "how to use Flink Map to build development environment and data". In the operation of actual cases, many people will encounter such a dilemma, so let the editor lead you to learn how to deal with these situations. I hope you can read it carefully and be able to achieve something!

Map operator: load the data stream one-to-one and return a new object

Sample environment

Java.version: 1.8.xflink.version: 1.11.1

Sample data source

Building Development Environment and data of Flink system example

Map.java

Import com.flink.demo.DataSource;import org.apache.flink.api.common.functions.MapFunction;import org.apache.flink.api.java.tuple.Tuple3;import org.apache.flink.streaming.api.datastream.DataStream;import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;import java.util.List Public class Map {/ * traverses the collection, printing the name * @ param args * @ throws Exception * / public static void main (String [] args) throws Exception {final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment (); List tuple3List = DataSource.getTuple3ToList () DataStream dataStream = env.fromCollection (tuple3List) .map (new MapFunction () {@ Override public String map (Tuple3 tuple3s) throws Exception {return tuple3s.f0;}); dataStream.print (); env.execute ("flink map job");}}

Print the result

4 > Wang Wu 3 > Li Si 1 > Liu Liu 3 > Wu Ba 2 > Zhang San 2 > Wu Qi "how to use Flink Map to build development environment and data" content is introduced here, thank you for reading. If you want to know more about the industry, you can follow the website, the editor will output more high-quality practical articles for you!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.