Flink 从0到1学习 —— 如何使用 Side Output 来分流? (mp.weixin.qq.com)

【简介】

之前在 Flink 从0到1学习—— Flink 不可以连续 Split(分流)? 讲过 Flink 使用连续的 Split 会有问题,当时提供了几种解决方法,有一种方法就是使用 Side Output 来进行,当时留了个余念,那么就在这篇文章详细的讲一波,教大家如何使用 Side Output 来分流。

点击查看全文 >>

@zhisheng_blog 2019-09-22 13:35分享 / 0个评论
赞过的人: IT技术博客大学习 zhisheng_blog
要不要再学学下面的文章?
凡人自保指南:武汉肺炎的个人防护、装备选择与使用建议 (mp.weixin.qq.com)
为帮助大家在未来的几个月内,武汉肺炎流行期间,采取必要且有效的措施,进行系统的自我保护,兼顾舒适性和外观等非专业部分,不谈真相,只聊实操。
by @又拍云 2020-02-05 11:29 分享 查看详情
Sublime Text 最详细的使用教程 (mp.weixin.qq.com)
本文系统全面的介绍了 Sublime Text,旨在成为最优秀的 Sublime Text 中文教程。
by @code小生 2020-02-03 16:40 分享 查看详情
如何学习Vue2源码 (rapheal.sinaapp.com)
近期我们把微信公众平台管理端的前端框架切成 MVVM 架构,框架层面最终我们选择了 Vue,为了更了解 Vue,阅读Vue源码是必要的。

我参考的 Vue 版本是 2.2.0,整个项目的代码1万2千行,如果不搞清楚原理,直接每一行看下来肯定会漏掉不少细节,或者对作者为什么这样写代码感到莫名其妙。

如此庞大的项目要啃下来并非易事,里边涉及到非常多的概念:Virtual Dom; 条件/列表渲染; 自定义组件; 双向绑定; 指令等等。

按照经验,编写这么庞大的系统,我们总是从第1行代码开始写起,慢慢写到第1万行,逐步构造出整个系统/框架。

所以我也会按照这个思路,从零开始构造出一个完整的Vue框架。
by @技术头条 2020-02-02 11:24 分享 查看详情
奇怪,免费版 IDEA 为什么不能使用 Tomcat 呢? (mp.weixin.qq.com)
IDEA有两大版本,一个是Ultimate版本,一个是Community版,ultimate是需要收费的,Community版是开源免费的。
by @code小生 2020-01-05 21:28 分享 查看详情
在 Flink 算子中使用多线程如何保证不丢数据? (yq.aliyun.com)
笔者线上有一个 Flink 任务消费 Kafka 数据,将数据转换后,在 Flink 的 Sink 算子内部调用第三方 api 将数据上报到第三方的数据分析平台。这里使用批量同步 api,即:每 50 条数据请求一次第三方接口,可以通过批量 api 来提高请求效率。由于调用的外网接口,所以每次调用 api 比较耗时。假如批次大小为 50,且请求接口的平均响应时间为 50ms,使用同步 api,因此第一次请求响应以后才会发起第二次请求。
by @可耐芊小仙女 2019-12-30 15:48 分享 查看详情
日处理数据量超10亿:友信金服基于Flink构建实时用户画像系统的实践 (yq.aliyun.com)
当今生活节奏日益加快,企业面对不断增加的海量信息,其信息筛选和处理效率低下的困扰与日俱增。由于用户营销不够细化,企业 App 中许多不合时宜或不合偏好的消息推送很大程度上影响了用户体验,甚至引发了用户流失。在此背景下,友信金服公司推行全域的数据体系战略,通过打通和整合集团各个业务线数据,利用大数据、人工智能等技术构建统一的数据资产,如 ID-Mapping、用户标签等。友信金服用户画像项目正是以此为背景成立,旨在实现“数据驱动业务与运营”的集团战略。目前该系统支持日处理数据量超 10 亿,接入上百种合规数据源。
by @可耐芊小仙女 2019-12-30 15:47 分享 查看详情
Android新版本(8.0以上)使用Toast的那些坑 (mp.weixin.qq.com)
查看Toast源码后发现,Toast显示要通过INotificationManager类来实现,而当通知禁用后,调用此类会返回异常,所以导致通知不显示,源码如下:
by @code小生 2019-12-25 12:57 分享 查看详情
Serverless 实战——使用 Rendertron 搭建 Headless Chrome 渲染解决方案 (yq.aliyun.com)
传统的 Web 页面,通常是服务端渲染的,而随着 SPA(Single-Page Application) 尤其是 React、Vue、Angular 为代表的前端框架的流行,越来越多的 Web App 使用的是客户端渲染。使用客户端渲染有着诸多优势,比如节省后端资源、局部刷新、前后端分离等等,但也带来了一些挑战,比如本文要解决的 SEO 问题。
by @可耐芊小仙女 2019-12-24 15:27 分享 查看详情
State Processor API:如何读取,写入和修改 Flink 应用程序的状态 (yq.aliyun.com)
过去无论您是在生产中使用,还是调研Apache Flink,估计您总是会问这样一个问题:我该如何访问和更新Flink保存点中保存的state?不用再询问了,Apache Flink 1.9.0引入了状态处理器API,它是基于DataSet API的强大扩展,允许读取,写入和修改Flink的保存点和检查点中的状态。
by @可耐芊小仙女 2019-12-24 15:25 分享 查看详情
Flink SQL 如何实现数据流的 Join? (yq.aliyun.com)
无论在 OLAP 还是 OLTP 领域,Join 都是业务常会涉及到且优化规则比较复杂的 SQL 语句。对于离线计算而言,经过数据库领域多年的积累,Join 语义以及实现已经十分成熟,然而对于近年来刚兴起的 Streaming SQL 来说 Join 却处于刚起步的状态。其中最为关键的问题在于 Join 的实现依赖于缓存整个数据集,而 Streaming SQL Join 的对象却是无限的数据流,内存压力和计算效率在长期运行来说都是不可避免的问题。
by @可耐芊小仙女 2019-12-24 15:23 分享 查看详情