开发者社区> 问答> 正文

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

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

展开
收起
游客qzzytmszf3zhq 2021-12-07 14:57:10 354 0
1 条回答
写回答
取消 提交回答
  • PyFlink 支持用户从一个列表创建源表。以下示例定义了包含了 3 行数据的表:[(1, 'aaa|bb'), (2, 'bb|a'), (3, 'aaa|a')],该表有 2 列,列名分别为 a 和 b,类型分别为 VARCHAR 和 BIGINT。
    
    ds = env.from_collection(
            collection=[(1, 'aaa|bb'), (2, 'bb|a'), (3, 'aaa|a')],
            type_info=Types.ROW([Types.INT(), Types.STRING()]))
    
    2021-12-07 14:57:21
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
开源广进-用Service Catalog构造K8S服务能力 立即下载
Apache Flink 流式应用中状态的数据结构定义升级 立即下载
低代码开发师(初级)实战教程 立即下载