AI 助理
备案控制台
开发者社区 大数据与机器学习 实时计算 Flink 正文

问下 java 项目 中使用 flink cdc mongodb 获得的数据 如何快速将数据转对象？

问下 java 项目 中使用 flink cdc mongodb 获得的数据 看文档是用 JsonDebeziumDeserializationSchema 进行序列化,但是 mongodb数据比较麻烦有其他方式快速将数据转对象吗？

展开
收起
wenti 2023-03-13 13:10:19 277 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 665661

    需要自己实现——该回答整理自钉群“Flink CDC 社区”

    2023-03-13 22:25:41
    赞同 展开评论
问答分类：
NoSQL Java MongoDB 流计算 实时计算 Flink版 云数据库 MongoDB 版
问答标签：
实时计算 Flink版CDC Java项目 Java对象 Java数据 实时计算 Flink版数据
问答地址：
开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答
相关问答
实时计算 Flink版
Flink CDC里抽取mongodb的数据时，所用的流量直接到158mb/s，有没有参数限制？
127
1
0
flink cdc同步MongoDB到mysql很慢，有什么方法可以就加快吗？
159
1
0
MongoDB CDC 在Flink CDC 2.2 版本中相比2.1版本有哪些改进？
60
1
0
flink cdc同步 mongodb支持用证书验证的方式嘛？
65
1
0
在Flink CDC中mongodb-cdc添加scan.full-changelog这参数后报错？
127
1
0
在Flink CDC中mongodb 运行在 atlas 是不是没法开启权限呀？
67
1
0
在Flink CDC中mongodb cdc拉不到数据，如何解决？
134
1
0
在Flink CDC中mongodb为什么同步完表里面的数据之后，作业就变成finished了呀？
218
9
0
flink mongodb cdc 使用sqlapi 到hudi里没有文件怎么办？
68
0
0
有哪位知道为啥Flink CDC Mongodb的updateLookup默认为true？
56
1
0
大数据与机器学习

实时计算 Flink

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

我要提问
收录在圈子:
阿里云实时计算Flink
199212
+ 订阅
实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

相关文章

  • 开发一套家政系统需要哪些关键技术？
  • 2025 校招必看：Java 开发面试核心知识点深度解析及最新笔面试题汇总
  • Springboot捕获feign抛出的异常
  • java静态方法和实例方法有何不同
  • 01开篇：如何拥有持续的获得感？

    • 热门讨论

    热门文章

  • Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题
  • 请问下大家有没有遇到过这个错:Caused by: java.lang.ClassNotFoundE
  • 大佬有遇见过这个错误的吗？连接kerberos的kafka的时候失败
  • flink的1cu是指1cpu还是1cpu+4g存储？
  • 请问flink1.19.1 standalone运行模式下checkpoint失败是什么原因？
  • FlinkCDC MySQL 中 scan.startup.mode 用的是什么模式啊？
  • 请问如何用flink sql客户端用yarn application模式提交任务呢？
  • Apache Flink未授权访问上传导致的RCE漏洞，这个漏洞目前方案解决吗？
  • Flink这个增量同步的问题应该是处理不够快导致反压，怎么解决啊？
  • 请问flink容器内存用到哪儿去了？
    • 展开全部
  • 数据仓库介绍与实时数仓案例
  • 权威详解 | 阿里新一代实时计算引擎 Blink，每秒支持数十亿次计算
  • 独家专访阿里集团副总裁贾扬清：我为什么选择加入阿里巴巴？
  • Flink SQL 功能解密系列 —— 维表 JOIN 与异步优化
  • 通过Flink实时构建搜索引擎的索引
  • Flume+Kafka+Flink+Redis构建大数据实时处理系统：实时统计网站PV、UV展示
  • 阿里云实时计算产品案例&解决方案汇总
  • Flink Checkpoint 问题排查实用指南
  • 史上超强阵容！大数据及人工智能领域顶级盛会，Flink Forward Asia 2019 不容错过！
  • 如何在 PyFlink 1.10 中自定义 Python UDF？
    • 展开全部
    还有其他疑问?
    咨询AI助理