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
>
>

Reply via email to