文章 2025-01-24 来自:开发者社区

微财基于 Flink 构造实时变量池

摘要:本文整理自微财资深数据开发工程师穆建魁老师在 Flink Forward Asia 2024 行业解决方案(一)专场中的分享。主要分为以下三个部分: 一、微财科技基于 Flink 构建时变量池分享 二、选择 Flink 进行流式计算的架构选型和开发效率提升策略 三、实时变量池架构与多流关联优化实践 一、微财科技基于 Flink 构建时变量池分享 本次分享的的主题是微财基于 Fli...

微财基于 Flink 构造实时变量池
问答 2023-06-29 来自:开发者社区

Flink CDC 2.4.0版本的PostgresSourceBuilder这构造是私有的,但是?

Flink CDC 2.4.0版本的PostgresSourceBuilder这构造是私有的,但是文档上说可以new出来,看了下代码里面好像没有构造实例的方法呢?

问答 2022-04-21 来自:开发者社区

Flink的Function里的成员变量可以直接在main中构造DAG时就在构造函数里赋么

Flink的Function里的成员变量可以直接在main中构造DAG时就在构造函数里赋么。是可序列化的,且不修改的。如果task restart 这个成员变量的值可以复原吧?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注