搜索[flink]结果-低调大师优秀个人博客

精选列表

搜索[flink]，共2086篇文章

回顾 | Apache Flink Meetup 杭州站圆满结束（附PPT下载）

id=116 《袋鼠云基于 Flink 实现的分布式数据同步工具 FlinkX 》徐超 | Flink contributor，袋鼠云资深技术专家嘉宾介绍：徐超，袋鼠云资深技术专家，Flink

2020-05-18

Iceberg 在基于 Flink 的流式数据入库场景中的应用

同时，为了支持流式数据的写入，我们引入 Flink 作为流式处理框架，并将 Iceberg 作为 Flink sink。下文主要介绍 Flink Iceberg sink 的实现框架和要点。

2020-04-14

Flink 如何支持特征工程、在线学习、在线预测等 AI 场景？

摘要：人工智能应用场景中，Flink 在包括特征工程，在线学习，在线预测等方面都有一些独特优势，为了更好的支持人工智能的使用场景，Flink 社区以及各个生态都在努力。

2020-03-12

Flink SQL 性能之旅

这就是 Flink 的 temporal table Join 的使用场景：在执行 join 时，fact_table 中的每一行都应该与来自相匹配维度表的最新行进行连接和合并。

2020-03-10

Apache Flink 与 Apache Hive 的集成

导读：随着 Flink 在流式计算的应用场景逐渐成熟和流行，如果 Flink 能同时把批量计算的应用场景处理好，就能减少用户在使用 Flink 时开发和维护的成本,并且能够丰富 Flink 的生态。

2020-03-04

Apache Flink 1.10.0 发布 | 云原生生态周报 Vol. 38

作者 | 徐迪、陈俊、敖小剑、宋进超业界要闻 Apache Flink 1.10.0 发布作为 Flink 社区迄今为止规模最大的一次版本升级，Flink 1.10 容纳了超过 200 位贡献者对超过

2020-02-20

Flink 1.10 和 Hive 3.0 性能对比（附 Demo 演示 PPT）

Flink 1.10 VS Hive 3.0 on Tez Flink 总时长的性能是 Hive on Tez 的 2.1 倍。

2020-02-19

Apache Flink 1.10.0 重磅发布，年度最大规模版本升级！

■ 其他优化除了分区剪枝，Flink 1.10 的 Hive 集成还引入了许多数据读取[19]方面的优化，例如：投影下推：Flink 采用了投影下推技术，通过在扫描表时忽略不必要的域，最小化 Flink

2020-02-12

Flink读取Kafka数据Sink到MySQL和HBase数据库

Flink将流数据Sink到数据库，一般需要自己自定义Sink的实现。下面示例，演示Sink到MySQL和HBase示例。

2020-01-14

在 Flink 算子中使用多线程如何保证不丢数据？

分析痛点笔者线上有一个 Flink 任务消费 Kafka 数据，将数据转换后，在 Flink 的 Sink 算子内部调用第三方 api 将数据上报到第三方的数据分析平台。

2019-12-24

Flink在大规模状态数据集下的checkpoint调优

笔者结合官方文档，给大家做个总结，也算是对Flink checkpoint机理的一个学习。

2019-08-16

58 集团大规模 Storm 任务平滑迁移至 Flink 的秘密

Flink-Storm 是 Flink 官方提供的用于 Flink 兼容 Storm 程序 beta 工具，并且在 Release 1.8 之后去掉相关代码。

2019-08-04

用Flink取代Spark Streaming！知乎实时数仓架构演进

实时数仓 2.0 版本，主题：数据分层，指标计算实时化，技术方案：Flink Streaming。实时数仓未来展望：Streaming SQL 平台化，元信息管理系统化，结果验收自动化。

2019-06-26

深度剖析阿里巴巴对Apache Flink的优化与改进

本文主要从两个层面深度剖析：阿里巴巴对Flink究竟做了哪些优化？

2019-04-29

Apache Flink，流计算？不仅仅是流计算！

作者：王峰（花名：莫问） 2018年12月下旬，由阿里巴巴集团主办的Flink Forward China在北京国家会议中心举行。

2019-01-04

flink内部计算指标的95线-99线等的实现

所以就直接写了下面的代码 PercentageCalculation.java package com.ymm.computation.udf.define; import org.apache.flink.table.functions.AggregateFunction

2018-12-20

G7在实时计算Flink的探索与实践

），应用逻辑与容错是分离的（算子处理和分布式快照checkpoint），基于以上我们认为flink是比较适合IoT这个场景的。

2018-11-13

Flink SQL 功能解密系列 —— 流计算“撤回(Retraction)”案例分析

什么是retraction（撤回）通俗讲retract就是传统数据里面的更新操作，也就是说retract是流式计算场景下对数据更新的处理方式。首先来看下流场景下的一个词频统计列子。没有retract会导致最终结果不正确↑： retract发挥的作用下面再分享两个双十一期间retract保证数据正确性的业务case: case1：菜鸟物流订单统计同一个订单的商品在运输过程中，因为各种原因，物流公司是有可能从A变成B的。为了统计物流公司承担的订单数目，菜鸟团队使用blink计算的retraction机制进行变key汇总操作。 -- TT source_table 数据如下： order_id tms_company 0001 中通 0002 中通 0003 圆通

2018-02-07

Flink SQL 功能解密系列 —— 维表 JOIN 与异步优化

本文主要讲解在 Flink SQL 中是如何解决这个问题的，用户如何简单上手使用这个功能。维表 JOIN 语法由于维表是一张不断变化的表（静态表只是动态表的一种特例）。

2018-02-07

Apache Flink：下一代大数据分析框架

文章讲的是 Apache Flink：下一代大数据分析框架， Apache Flink是一个用于大数据处理的Apache项目。虽然它看起来像Apache Spark，但二者在架构和想法上有很大差异。

2017-08-31

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

WebStorm

WebStorm 是jetbrains公司旗下一款JavaScript 开发工具。目前已经被广大中国JS开发者誉为“Web前端开发神器”、“最强大的HTML5编辑器”、“最智能的JavaScript IDE”等。与IntelliJ IDEA同源，继承了IntelliJ IDEA强大的JS部分的功能。