写回答
-
面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。Flink 可以接收 OGG （Oracle GoldenGate）格式的数据，但需要借助一些第三方工具或插件才能实现。这是因为 Flink 并不直接支持 OGG 格式的输入，而 OGG 格式通常是通过特殊的 API 或插件来进行读取的。
要将 OGG 格式的数据输入到 Flink 中，一种可能的方法是使用开源的 Kettle 工具或者 Talend 工具来实现数据的转换。这些工具提供了丰富的 ETL 功能，可以方便地将 OGG 格式的数据转换为 Flink 支持的其他格式，如 CSV、JSON 等，然后再通过 Flink 提供的各种输入源将这些数据导入到 Flink 中。
另外，也有一些第三方的插件可以直接将 OGG 格式的数据输入到 Flink 中，如 Flume、Kafka 等。这些插件通常会将 OGG 格式的数据转换为某种中间格式，然后再通过 Flink 提供的各种输入源将这些数据导入到 Flink 中。
总的来说，虽然 Flink 直接支持 OGG 格式的输入较为困难，但是通过一些第三方工具或插件，我们可以将 OGG 格式的数据输入到 Flink 中。2023-10-31 14:52:56赞同 展开评论 打赏 -
是的，Flink支持接收Ogg数据。Flink可以使用Ogg JSON消息作为输入，将这些消息解析为INSERT/UPDATE/DELETE消息，然后将这些消息发送到Flink SQL系统中。这种特性在很多场景中非常有用，例如将增量数据从数据库同步到其他系统，进行日志审计，创建数据库的实时物化视图，更新关联维度数据库的变更历史等。
然而，需要注意的是，Flink目前还不支持将UPDATE_BEFORE和UPDATE_AFTER合并为一条UPDATE消息。
2023-10-31 14:43:44赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关文章
相关电子书
更多
