栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink之project

Flink之project

作用

主要是用于获取元组中指定字段的值,注意只能用于元组,不能用在其他数据类型。

代码
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment executionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment();
        executionEnvironment.setParallelism(1);
        DataStream> dataStream1 = executionEnvironment.fromCollection(Arrays.asList(
                new Tuple3("sensor_1", 1547718199, 35.8),
                new Tuple3("sensor_6", 1547718201, 15.4),
                new Tuple3("sensor_7", 1547718202, 6.7),
                new Tuple3("sensor_6", 1547718203, 15.9),
                new Tuple3("sensor_10", 1547718205, 38.1),
                new Tuple3("sensor_6", 1547718206, 15.1),
                new Tuple3("sensor_6", 1547718209, 15.0)
        ));
        SingleOutputStreamOperator projectStream = dataStream1.project(0, 2);
        projectStream.print();

结果:

(sensor_1,35.8)
(sensor_6,15.4)
(sensor_7,6.7)
(sensor_6,15.9)
(sensor_10,38.1)
(sensor_6,15.1)
(sensor_6,15.0)

Process finished with exit code 0

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/604084.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号