开发者社区> 问答> 正文

PyFlink中使用catalog创建数据源表的方法是什么?

PyFlink中使用catalog创建数据源表的方法是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 14:41:41 385 0
1 条回答
写回答
取消 提交回答
  • hive_catalog = HiveCatalog("hive_catalog")
    t_env.register_catalog("hive_catalog", hive_catalog)
    t_env.use_catalog("hive_catalog")
    
    # 假设hive catalog中已经定义了一个名字为source_table的表
    tab = t_env.from_path('source_table')
    
    2021-12-07 14:41:55
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
HBase Schema 设计 立即下载
基于 Flink SQL + Paimon 构建流式湖仓新方 立即下载
大批量处理excel文件到ODPS中方案 立即下载