95-230-020-源码-WordCount走读-获取StreamGraph的过程

1.视界

在这里插入图片描述

2.执行程序

需要执行任务,这时会调用如下代码:

env.execute("Socket Window WordCount");

在StreamExecutionEnvironment中,这是一个抽象方法,具体的实现在其子类中,其子类StreamContextEnvironment的实现如下:

public JobExecutionResult execute() throws Exception 

猜你喜欢

转载自blog.csdn.net/qq_21383435/article/details/105748353
今日推荐