开发者社区 问答 正文

PyFlink中创建 StreamExecutionEnvironment 对象的方法是什么?

PyFlink中创建 StreamExecutionEnvironment 对象的方法是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 14:55:36 419 分享 版权
1 条回答
写回答
取消 提交回答
  • 对于 DataStream API 作业来说,用户首先需要定义一个 StreamExecutionEnvironment 对象。
    
    env = StreamExecutionEnvironment.get_execution_environment()
    
    2021-12-07 14:55:48
    赞同 展开评论
问答分类:
问答地址: