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

请问一下使用flinkcdc将hudi数据同步到hive,关于timestamp数据类型有什么办法?

请问一下使用flinkcdc将hudi数据同步到hive,关于timestamp数据类型有什么办法不转成long类型的方法么?

展开
收起
真的很搞笑 2023-08-22 17:12:14 105 0
1 条回答
写回答
取消 提交回答
  • 可以通过如下方式将hudi数据中 timestamp 类型的数据同步到 hive:

    在hudi表字段上定义 ROW_TIMESTAMP() 函数。
    在flinkcdc程序中使用 hudi-sql-metadata 编译器生成 DDL。
    使用 hudi-flink 插件将hudi表中的数据同步到 hive。

    2023-09-20 10:48:13
    赞同 展开评论 打赏

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

相关电子书

更多
spark替代HIVE实现ETL作业 立即下载
2019大数据技术公开课第五季—Hive迁移到MaxCompute最佳实践 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载