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

精选列表

搜索[flink]，共2085篇文章

PieCloudDB Database Flink Connector: 让数据流动起来

经过多年的发展，整个 Flink 社区已经围绕 Flink 构成出了一个丰富的生态系统。

2024-05-31

使用Flink完成流数据统计 | 京东云技术团队

包括数据源，每一次发射出来的数据结果都通过DataStream来传递给下一级继续处理每一个Transformation要有2步： 1、处理数据 2、将处理完的数据发射出去二、Flink的数据源 Flink

2023-12-11

Flink OLAP 在字节跳动的查询优化和落地实践

本文整理自字节跳动基础架构工程师何润康在 Flink Forward Asia 2022 核心技术专场的分享。

2023-04-12

阿里妈妈Dolphin智能计算引擎基于Flink+Hologres实践

来完成，那么我们为什么选择Flink+Hologres这套架构呢？

2023-01-12

打造通用缓存层：字节跳动 Flink StateBackend 性能提升之路

内容简介：StateBackend 作为 Flink 向上提供 State 能力的基石，其性能会严重影响任务的吞吐。

2022-09-22

Flink OLAP 助力 ByteHTAP 亮相数据库顶会 VLDB

ByteHTAP 使用 Flink 作为 OLAP 计算引擎，在计算和存储中引入了一些重要的性能优化，例如重构 Flink 作业调度流程以提升查询 QPS，将计算推到存储层，以及使用删除位图来有效地处理删除等

2022-09-14

实时计算框架：Flink集群搭建与运行机制

一、Flink概述 1、基础简介 Flink是一个框架和分布式处理引擎，用于对***和有界数据流进行有状态计算。Flink被设计在所有常见的集群环境中运行，以内存执行速度和任意规模来执行计算。

2021-05-09

[源码分析] 带你梳理 Flink SQL / Table API内部执行流程

Flink关系型API执行原理 2. Flink Sql 执行流程 3. Flink Table Api 执行流程 4. Flink Table/SQL 执行流程的异同 1.

2021-04-26

Flink 执行引擎：流批一体的融合之路

简介：本文由 Apache Flink Committer 马国维分享，主要介绍 Flink 作为大数据计算引擎的流批一体融合之路。

2021-03-26

Flink 在又拍云日志批处理中的实践

大家好，我是来自又拍云的张召，今天主要分享又拍云多数据源日志处理选型 Flink 的考量，以及 Flink 落地过程中遇到的问题和解决方案。

2021-02-03

腾讯基于 Flink SQL 的功能扩展与深度优化实践

整理：戴季国（Flink社区志愿者）校对：苗文婷（Flink 社区志愿者）摘要：本文由腾讯高级工程师杜立分享，主要介绍腾讯实时计算平台针对 Flink SQL 所做的优化，内容包括： Flink

2021-02-02

为何放弃数据库，Hive和Spark,偏偏选择Flink?

Spark 和 Flink 正是这样的场景. Spark 与 Flink 初次交锋 Spark 和 Flink 之间, 我们毫不犹豫地选择了 Spark. 原因非常简单: Spark 适合批处理.

2020-10-12

深入解读flink sql cdc的使用以及源码分析

前言 flink消费cdc数据 canal format debezium format CanalJson反序列化源码解析 flink cdc connector 背景 mysql-cdc mysql-cdc

2020-09-14

进击的 Flink：网易云音乐实时数仓建设实践

作者 | 汪磊（网易云音乐 / 数据平台开发专家）整理 | 杨涛（Flink 社区志愿者）如何基于 Flink 的新 API 升级实时数仓架构？

2020-07-23

详解 Flink DataStream中min(),minBy(),max(),max()之间的区别

解释官方文档中: The difference between min and minBy is that min returns the minimum value, whereas minBy returns the element that has the minimum value in this field (same for max and maxBy). 翻译: min和minBy之间的区别是min返回最小值，而minBy返回在此字段中具有最小值的元素（与max和maxBy相同）。但是事实上,min与max 也会返回整个元素。不同的是min会根据指定的字段取最小值，并且把这个值保存在对应的位置上，对于其他的字段取了最先获取的值，不能保证每个元素的数值正确，max同理。而minBy会返回指定字段取最小值的元素，并且会覆盖指定字段小于当前已找到的最小值元素。maxBy同理。示例论证先拿min()与minBy()举例: 取第三个元素的最小值 public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); //获取数据源 List data = new ArrayList<Tuple3<Integer,Integer,Integer>>(); data.add(new Tuple3<>(0,2,2)); data.add(new Tuple3<>(0,1,1)); data.add(new Tuple3<>(0,5,6)); data.add(new Tuple3<>(0,3,5)); data.add(new Tuple3<>(1,1,9)); data.add(new Tuple3<>(1,2,8)); data.add(new Tuple3<>(1,3,10)); data.add(new Tuple3<>(1,2,9)); DataStreamSource<Tuple3<Integer,Integer,Integer>> items = env.fromCollection(data); items.keyBy(0).min(2).print(); env.execute("defined streaming source"); } 输出结果: (0,2,2) (0,2,1) (0,2,1) (0,2,1) (1,1,9) (1,1,8) (1,1,8) (1,1,8) 可以看到返回的元素第二个字段取的是获取到第一个元素的字段值; 往下找,第二个元素的指定值是最小的，则把这个值保存的对应位置。接下来再看minBy()的运行结果: (0,2,2) (0,1,1) (0,1,1) (0,1,1) (1,1,9) (1,2,8) (1,2,8) (1,2,8) 返回的是指定字段最小值的元素。可以看到元素数值的正确。当然max(),maxBy同理。更多文章:www.ipooli.com

2020-06-09

两位 Apache Flink PMC 喜提 Apache Member

摘要：近期 Apache 软件基金会（以下简称 ASF ）举行了一年一度的董事会选举会议，两位 Apache Flink PMC 当选为 2020 年 ASF 新成员，即 Apache Member。

2020-04-12

Maven 私服无法下载 flink 2.11 最新组件事件回顾

打开 Maven 私服，发现 Central 仓库无法浏览远程存储，报500错误打开 https://search.maven.org/搜索flink-scala_2.11 组件并下载可以下载成功

2020-02-27

看完这份知识图谱，才算搞懂 Flink！

即日起，Apache Flink 社区微信公众号 Ververica 正式更名为 Flink 中文社区并由 Apache Flink PMC 成员进行维护，是国内唯一的 Flink 社区官方微信公众号

2020-02-12

美团点评基于 Flink 的实时数仓平台实践

在 2017 年底，美团点评实时计算平台引入了 Flink。相比于 Storm 和 Spark Streaming，Flink 在很多方面都具有优势。

2020-01-01

资源下载

更多资源

Mario

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

腾讯云软件源

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

Nacos

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

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。