开发者社区 > 大数据与机器学习 > 实时数仓 Hologres > 正文

Flink api 怎么读Hologres 的分区表?

Flink api 怎么读Hologres 的分区表?

展开
收起
嘟嘟嘟嘟嘟嘟 2024-06-05 08:47:25 67 0
2 条回答
写回答
取消 提交回答
  • 依赖配置:确保项目中引入了Hologres DataStream连接器。针对VVR 6.0.7版本,使用1.15-vvr-6.0.7-1版本的依赖。

    读取数据:利用Hologres提供的HologresBulkreadInputFormat,这是一个RichInputFormat的实现,专门用于读取Hologres表数据。构建数据源时,参考相关示例代码来配置和初始化HologresBulkreadInputFormat,以指向目标分区表。

    2024-06-05 09:19:05
    赞同 1 展开评论 打赏
  • 北京阿里云ACE会长

    添加依赖:首先需要在 Flink 项目的 pom.xml 文件中添加 Hologres JDBC 驱动的依赖。

    配置连接:在 Flink 程序中配置数据库连接信息,包括数据库地址、端口、用户名、密码image.png

    2024-06-05 09:08:39
    赞同 2 展开评论 打赏

本技术圈将为大家分析有关阿里云产品Hologres的最新产品动态、技术解读等,也欢迎大家加入钉钉群--实时数仓Hologres交流群32314975

相关产品

  • 实时数仓 Hologres
  • 相关电子书

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