专栏首页cosmozhu技术篇Flink-1.9流计算开发:十四、union函数

Flink-1.9流计算开发:十四、union函数

1+

Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十四、union函数》cosmozhu写的本系列文章的第十四篇。通过简单的DEMO来演示union函数执行的效果 。

需求

本篇文章我们看一下union的用法,将多个币种的汇率流合并成一个汇率流。

解决方案

    public static void main(String[] args) throws Exception {

        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        //USD -> CNY 汇率流
        DataStreamSource<ExchangeRateInfo> usdToCny = env.addSource(new ExchangeRateDataSource(CurrencyType.USD, CurrencyType.CNY, 7, 6),"USD-CNY");
        //EUR -> CNY 汇率流
        DataStreamSource<ExchangeRateInfo> eurToCny = env.addSource(new ExchangeRateDataSource(CurrencyType.EUR, CurrencyType.CNY, 8, 7),"EUR-CNY");
        //AUD -> CNY 汇率流
        DataStreamSource<ExchangeRateInfo> audToCny = env.addSource(new ExchangeRateDataSource(CurrencyType.AUD, CurrencyType.CNY, 5, 4),"AUD-CNY");
        //三个流合并为一个流
        DataStream<ExchangeRateInfo> allExchangeRate = usdToCny.union(eurToCny).union(audToCny);
        //将流标准输出
        allExchangeRate.print();

        env.execute("Flink Streaming Java API Skeleton");
    }

执行效果

通过union函数将 USD -> CNY 汇率流 EUR -> CNY 汇率流 AUD -> CNY 汇率流

统一合并成一个汇率流

1> ExchangeRateInfo [from=AUD, to=CNY, coefficient=4.60]
1> ExchangeRateInfo [from=USD, to=CNY, coefficient=6.74]
1> ExchangeRateInfo [from=EUR, to=CNY, coefficient=7.05]
2> ExchangeRateInfo [from=AUD, to=CNY, coefficient=4.03]
2> ExchangeRateInfo [from=USD, to=CNY, coefficient=6.36]
2> ExchangeRateInfo [from=EUR, to=CNY, coefficient=7.83]
3> ExchangeRateInfo [from=AUD, to=CNY, coefficient=4.31]
3> ExchangeRateInfo [from=USD, to=CNY, coefficient=6.71]
3> ExchangeRateInfo [from=EUR, to=CNY, coefficient=7.79]
4> ExchangeRateInfo [from=AUD, to=CNY, coefficient=4.08]
4> ExchangeRateInfo [from=USD, to=CNY, coefficient=6.21]
4> ExchangeRateInfo [from=EUR, to=CNY, coefficient=7.46]

小结

在sql中union是将多个查询结果集合汇总成一个结果集合,而在流计算中类似的将多个流合并成一个流。

代码地址

https://github.com/chaoxxx/learn-flink-stream-api/blob/master/src/main/java/fun/cosmozhu/session14/main/StreamTest.java

作者:cosmozhu --90后的老父亲,专注于保护地球的程序员 个人网站:https://www.cosmozhu.fun 欢迎转载,转载时请注明出处。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Flink-1.9流计算开发:十六、intervalJoin函数

    flink intervalJoin,Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:十六、intervalJoin函...

    cosmozhu
  • Flink-1.9流计算开发:一、最初的开始HELLO WORLD

    首先我们需要需要了解的一个概念是Apache Flink支持处理流式计算(stream)和批量计算(batch),但是在目前版本中这两种计算方式各自拥有自己独立...

    cosmozhu
  • Flink-1.9流计算开发:九、time-window-sliding窗口函数

    Flink是下一代大数据计算平台,可处理流计算和批量计算。《Flink-1.9流计算开发:九、time-window-sliding》cosmozhu写的本系列...

    cosmozhu
  • 性能测试必备知识(8)- 深入理解“进程状态”

    小菠萝测试笔记
  • 2018网络创业项目:速成应用小程序开发制作代理

    速成应用小程序工具平台、海量行业模板,可视化编辑工具、小程序可视化编辑工具!在线拖拉组件,全自主布局,基于微信UI设计规则的产品架构,成熟的模板套用,一键生成小...

    速成应用小程序
  • python slice的几个小点总结

    最近在看python时发现python中关于序列的操作,尤其slice的用法挺特别的,遂上网又细细查了查资料,感觉这篇文章总结的很好,就转载下来,留个记录。原...

    py3study
  • 大型Bat面试知识总结分享—AMS在Android起到什么作用?简单的分析下Android的源码

    相信大多数动脑同学对文章中提到的ActivityManagerService(以后简称AMS)都有所耳闻。

    Android技术干货分享
  • clickAwayHook Vue 监听元素外事件 hook

    copy_left
  • 进程通信概念简介 多线程上篇(六)

    进程通信指的是进程间的信息交换 ,IPC(Inter-Process Communication,进程间通信)

    noteless
  • PHP manual(update)

    直接改变数组的值自 PHP 5 起可以通过引用传递来做到。之前的版本需要需要采取变通的方法

    仇诺伊

扫码关注云+社区

领取腾讯云代金券