Hi Fabian,
        I realized that scenario later :)
        Thank you all the same.

Best
Henry


> 在 2018年9月18日,下午4:10,Fabian Hueske <fhue...@gmail.com> 写道:
> 
> 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 
> <mailto: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 <mailto: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
> 

Reply via email to