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

This article mainly explains "how to use Flink Project". The content in the article is simple and clear, and it is easy to learn and understand. Please follow the editor's train of thought to study and learn how to use Flink Project.

Project operator: from the tuple array of the data flow, rearrange the parameters and specify different subscript bits to return the new data stream

Sample environment

Java.version: 1.8.xflink.version: 1.11.1

Sample data source (project code cloud download)

Building Development Environment and data of Flink system example

Project.java

Import com.flink.examples.DataSource;import org.apache.flink.api.java.tuple.Tuple2;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 / * * @ Description Project operator: from the tuple array of the data flow, rearrange the parameters and specify different subscript bits Return new data stream * / public class Project {/ * * official document: https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/stream/operators/ * / / * reorder and assemble a new data source on the original data source And print * @ param args * @ throws Exception * / public static void main (String [] args) throws Exception {final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment () List tuple3List = DataSource.getTuple3ToList (); / / project (index subscript, index subscript). The project parameter corresponds to the subscript of Tuple3 in the data stream. Multiple subscript bits can be specified to return a new data stream containing Tuple: DataStream dataStream = env.fromCollection (tuple3List) .project (2J0); dataStream.print (); env.execute ("flink Project job");}}

Print the result

1 > (29, Wang Wu) 3 > (20, Zhang San) 2 > (32, Liu Liu) 3 > (18, Wu Qi) 4 > (24, Li Si) 4 > (30, Wu Ba) Thank you for your reading. the above is the content of "how to use Flink Project". After the study of this article, I believe you have a deeper understanding of how to use Flink Project, and the specific use needs to be verified in practice. Here is, the editor will push for you more related knowledge points of the article, welcome to follow!

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.