Flink Project怎么用

发布时间:2021-12-31 10:27:01 作者:iii
来源:亿速云 阅读:149

这篇文章主要讲解了“Flink Project怎么用”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Flink Project怎么用”吧!

Project算子:从数据流的元数组中,重新排例参数并指定不同的下标位,返回新的数据流

示例环境

java.version: 1.8.x
flink.version: 1.11.1

示例数据源 (项目码云下载)

Flink 系例 之 搭建开发环境与数据

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算子:从数据流的元数组中,重新排例参数并指定不同的下标位,返回新的数据流
 */
public class Project {

    /**
     * 官方文档:https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/stream/operators/
     */

    /**
     * 在原有的数据源上重新排序组装一个新的数据源,并打印
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception {
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        List<Tuple3<String,String,Integer>> tuple3List = DataSource.getTuple3ToList();
        //project(索引下标,索引下标),project参数对应数据流中Tuple3的下标位,可以指定多个下标位,返回一个新包含Tuple的数据流
        DataStream<Tuple2<Integer, String>> dataStream = env.fromCollection(tuple3List).project(2,0);
        dataStream.print();
        env.execute("flink Project job");
    }
}

打印结果

1> (29,王五)3> (20,张三)2> (32,刘六)3> (18,伍七)4> (24,李四)4> (30,吴八)

感谢各位的阅读,以上就是“Flink Project怎么用”的内容了,经过本文的学习后,相信大家对Flink Project怎么用这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是亿速云,小编将为大家推送更多相关知识点的文章,欢迎关注!

推荐阅读:
  1. flink 多表join的例子
  2. 大数据IDEA调试flink程序

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

flink project

上一篇:怎么通过公式处理让SAP Analytics Cloud里的dimension符合Date格式需求

下一篇:Flink中Watermarks怎么用

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》