提交 1971b67b 编写于 作者: G ghermann 提交者: Stephan Ewen

[streaming] Added JobGraphBuilder getter to StreamExecEnv

上级 453acfbf
......@@ -102,4 +102,8 @@ public class StreamExecutionEnvironment {
jobGraphBuilder.setSource(returnStream.getId(), DummySource.class);
return returnStream;
}
public JobGraphBuilder jobGB() {
return jobGraphBuilder;
}
}
......@@ -38,6 +38,7 @@ public class DataStreamTest {
DataStream<Tuple1<String>> dataStream = context.setDummySource().flatMap(new MyFlatMap());
JobGraphBuilder jgb = context.jobGB();
context.execute(dataStream.getId());
//
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册