开发者社区> 问答> 正文

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

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

展开
收起
游客qzzytmszf3zhq 2021-12-07 14:40:35 438 0
1 条回答
写回答
取消 提交回答
  • PyFlink 支持用户从一个给定列表,创建源表。以下示例定义了包含了 3 行数据的表:[("hello", 1), ("world", 2), ("flink", 3)],该表有 2 列,列名分别为 a 和 b,类型分别为 VARCHAR 和 BIGINT。
    
    tab = t_env.from_elements([("hello", 1), ("world", 2), ("flink", 3)], ['a', 'b'])
    
    2021-12-07 14:40:51
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Get rid of traditional ETL, Move to Spark! 立即下载
Phoenix Search Index 功能与应用场景介绍 立即下载
Dynamic DDL Adding Structure to Streaming Data on the Fly 立即下载