开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC的时候有没有办法取到source表的metadata?

Flink CDC的时候有没有办法取到source表的metadata?

展开
收起
真的很搞笑 2023-09-27 08:02:46 334 0
1 条回答
写回答
取消 提交回答
  • Flink CDC可以通过CDCSourceContext.getOffset方法获取到source表的metadata。这个方法会返回一个OffsetContext对象,其中包含了source表的所有metadata。

    以下是获取source表的metadata的示例代码:

    OffsetContext offsetContext = sourceContext.getOffset();

    // 获取source表的名称
    String table = offsetContext.getDatabase() + "." + offsetContext.getTable();

    // 获取source表的schema
    TableSchema schema = offsetContext.getSchema();

    // 获取source表的partitions
    Map partitions = offsetContext.getPartitions();
    通过这些metadata,你可以获取到source表的所有信息,包括名称、schema、partitions等。

    2023-10-11 10:32:05
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载