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
