最新 最热

【Spark重点难点】你从未深入理解的RDD和关键角色

之前我们成功完成了Flink重点难点部分的学习了。很多同学可能还没有意识到,你已经把Flink这个框架中最关键的部分掌握了。Flink的重点难点部分就是我列在这里的部分:...

2021-12-02
1

Flink基础教程

第 1 章 为何选择 Flink许多情况下,人们希望用低延迟或者实时的流处理来获得数据的高时效性,前提是流处理本身是准确且高效的优秀的流处理技术可以容错,而且能保证exactlyonce2Storm提供了低延迟的流处理,但是它为实时性...

2021-12-01
0

基于流计算 Oceanus 和 Elasticsearch Service 构建百亿级实时监控系统

在后移动互联网时代,良好的用户体验是增长的基础,而稳定的使用体验则是用户体验的基础。大型的互联网公司,尤其是面向 C 端客户的公司,对业务系统稳定性的要求越来越高,因此对线上问题发现和处理的速度要求通常是分钟级的...

2021-11-29
1

用 Apache NiFi、Kafka和 Flink SQL 做股票智能分析

本文是关于如何在实时分析中使用云原生应用程序对股票数据进行连续 SQL 操作的教程。

2021-11-28
1

Kafka Stream(KStream) vs Apache Flink

腾讯云流计算 Oceanus 是大数据实时化分析利器,兼容 Apache Flink 应用程序。新用户可以 1 元购买流计算 Oceanus(Flink) 集群,欢迎读者们体验使用。

2021-11-28
1

【技术种草】我用 1个肉夹馍的钱,搭了整套大数据系统

下面我分享一下如何用 1 个肉夹馍的钱来搭建一套云上的大数据平台。经过本人反复的钻研,发现薅羊毛这件事简直是太简单了。最后买 MySQL 19.9元,流计算 Oceanus(Flink) 1 元,花了二十几块钱,搭建了这样式的大数据系统。...

2021-11-26
1

flink rocketmq消费和写入数据

通过yaml文件可知总共有三个组件:分别为nameserver, broker, web console

2021-11-24
0

5分钟实现第一个Flink程序

用IDE打开这个项目,里面已经创建了两个类StreamingJob和BatchJob,本文使用StreamingJob来完成一个实时统计单词的任务

2021-11-24
0

Flink重点难点:状态(Checkpoint和Savepoint)容错与两阶段提交

在 Flink 的框架中,进行有状态的计算是 Flink 最重要的特性之一。所谓的状态,其实指的是 Flink 程序的中间计算结果。Flink 支持了不同类型的状态,并且针对状态的持久化还提供了专门的机制和状态管理器。...

2021-11-23
0

Flink重点难点:Flink任务综合调优(Checkpoint/反压/内存)

我们在Flink重点难点:状态(Checkpoint和Savepoint)容错与两阶段提交一文中对Flink的Checkpoint做过详细的介绍。

2021-11-23
0