Hi, Any operator can have multiple out-going edges. If you implement something like:
DataStream<X> instream = ... DataStream<Y> outstream1 = instream.map(new MapFunc1()); DataStream<Z> outstream2 = instream.map(new MapFunc2()); The node representing instream will have two outgoing edges that lead to the two Map nodes. Best, Fabian 2018-09-18 5:25 GMT+02:00 vino yang <yanghua1...@gmail.com>: > Hi tao, > > The Dataflow abstraction of Flink runtime is a DAG. In a graph, there may > be more than one in-edge and one out-edge. > A simple example of multiple out margins is that an operator is followed > by multiple sinks. > For example, a sink to kafka and a sink to elasticsearch. > > Thanks, vino. > > 徐涛 <happydexu...@gmail.com> 于2018年9月18日周二 上午10:34写道： > >> Hi All, >> I am reading the source code of flink, when I read the >> StreamGraph generate part, I found that there is a property named outEdges >> in StreamNode. I know there is a case a StreamNode has multiple inEdges, >> but in which case the StreamNode has multiple outEdges? >> Thanks a lot. >> >> Best >> Henry > >
