开发者社区 问答 正文

使用 PyFlink Table API 中定义的 connector创建数据源的说明是什么?

使用 PyFlink Table API 中定义的 connector创建数据源的说明是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 15:00:42 384 分享 版权
1 条回答
写回答
取消 提交回答
  • 说明:
    
    由于当前 PyFlink DataStream API 中 built-in 支持的 connector 种类还比较少,推荐通过这种方式来创建 PyFlink DataStream API 作业中使用的数据源表,这样的话,所有 PyFlink Table API 中可以使用的 connector,都可以在 PyFlink DataStream API 作业中使用。
    需要注意的是,TableEnvironment 需要通过以下方式创建 StreamTableEnvironment.create(stream_execution_environment=env),以使得 PyFlink DataStream API 与 PyFlink Table API 共享同一个 StreamExecutionEnvironment 对象。
    
    2021-12-07 15:00:54
    赞同 展开评论