阿里云文档 2026-01-07

Connector数据结构说明-实时计算 Flink版-阿里云

名称类型描述示例值object自定义连接器 connector。namestringconnector 名称。mysql-testtypestringconnector 类型。mysql-testsourceboolean是否可以作为 source。falsesinkboolean是否可以作为 si...

阿里云文档 2025-09-16

如何使用新版Flink Connector将数据写入MaxCompute,有哪些参数

MaxCompute提供了新版Flink Connector插件,支持将Flink数据写入至MaxCompute的普通表和Delta Table类型表,以提高Flink数据写入MaxCompute的便捷性。本文介绍新版Flink Connector写入MaxCompute的能力支持情况与主要操作流程。

阿里云文档 2025-07-29

从Apache Flink持续导入

StarRocks提供Apache Flink连接器(以下简称Flink Connector),可以通过Flink导入数据至StarRocks表。相比于Flink自带的flink-connector-jdbc,StarRocks的Flink Connector性能更优越且稳定性更强,特别适合大规模数据导入场景。

阿里云文档 2024-10-22

Flink Connector 相关配置

Flink Connector 使用

文章 2023-11-22 来自:开发者社区

flink tdsql cdc connector开发(已开源)

01 引言最近需要对接腾讯的tdsql,准备使用flink的mysql cdc jar,发现该jar包并不支持tdsql(5.x版本),运行时总是一堆的报错。报错的根本原因是:flink的mysql cdc jar包里面是基于mysql8.x驱动来打包的,而该版本的tdsql仅支持的jdbc驱动为5.x。因此,需要做的事情就是降级mysql cdc jar包里面的mysql驱动并重新打包,而my....

flink tdsql cdc connector开发(已开源)
文章 2023-10-16 来自:开发者社区

flink tdsql cdc connector开发(已开源)

01 引言 最近需要对接腾讯的tdsql,准备使用flink的[mysql cdc jar],发现该jar包并不支持tdsql(5.x版本),运行时总是一堆的报错。报错的根本原因是:flink的mysql cdc jar包里面是基于mysql8.x驱动来打包的,而该版本的tdsql仅支持的jdbc驱动为5.x。因此,需要做的事情就是降级mysql cdc jar包里面的mysql驱动并重新打包,....

flink tdsql cdc connector开发(已开源)
阿里云文档 2023-09-03

FlinkConnector的使用方式及示例_EMR on ECS_开源大数据平台 E-MapReduce(EMR)

Flink Connector内部实现是通过缓存并批量由Stream Load导入。本文为您介绍Flink Connector的使用方式及示例。

文章 2022-10-24 来自:开发者社区

《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》电子版地址

《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》基于 Flink 的全新 Pulsar Connector 的设计、开发和使用 电子版下载地址: https://developer.aliyun.com/ebook/457 电子书: </div>

《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》电子版地址

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注