阿里云文档 2024-07-31

Source变更兼容性

本文为您介绍Source变更的可兼容性和不可兼容性详情。

问答 2024-07-15 来自:开发者社区

在Flink CDC中有没有用DataStream Source 方式 MySqlSource ?

在Flink CDC中有没有用DataStream Source 方式 MySqlSource ,同步mysql 到 doris的?

阿里云文档 2024-07-10

SQL变更的其他兼容性限制

本文为您介绍变更SQL除Query、Source和Sink之外的其他限制。

文章 2023-12-06 来自:开发者社区

Flink(四)【DataStream API - Source算子】

前言        今天开始学习 DataStream 的 API ,这一块是 Flink 的核心部分,我们不去学习 DataSet 的 API 了,因为从 Flink 12 开始已经实现了流批一体, DataSet 已然是被抛弃了。忘记提了,从这里开始,我开始换用 Flink 17 了。一个 Flink 程序,其实就是对 DataStream 的各种转换....

文章 2022-06-12 来自:开发者社区

【Flink】(三)详解 Flink DataStream API(Environment、Source、Transform、Sink)2

四、支持的数据类型Flink 流应用程序处理的是以数据对象表示的事件流。所以在 Flink 内部,我们需要能够处理这些对象。它们需要被序列化和反序列化,以便通过网络传送它们;或者从状态后端、检查点和保存点读取它们。为了有效地做到这一点,Flink 需要明确知道应用程序所处理的数据类型。Flink 使用类型信息的概念来表示数据类型,并为每个数据类型生成特定的序列化器、反序列化器和比较器。Flink....

文章 2022-06-12 来自:开发者社区

【Flink】(三)详解 Flink DataStream API(Environment、Source、Transform、Sink)1

文章目录一、Environment      1.1 getExecutionEnvironment1.2 createLocalEnvironment1.3 createRemoteEnvironment二、Source2.1 从集合读取数据2.2 从文件读取数据2.3 以 kafka 消息队列的数据作为来源2.4 自定义 Source三、转换算子(Transfo....

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

产品推荐

实时计算 Flink

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

+关注