flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From CPC <acha...@gmail.com>
Subject DagConnection tempMode vs breakPipeline property
Date Thu, 16 Jun 2016 14:46:25 GMT
Hi everybody,

I am trying to understand flink optimizer in DataSet api. But i dont
understant tempMode and breakPipeline properties. TempMode enum also has a
breakPipeline property but they both accessed and set in different places.
DagConnection.breakPipeline is used to select network io DataExchangeMode.
Though i dont understand DagConnection.TempMode and also tempMode in
Channel. Could somebody explain why there is two different breakPipeline
property and the duty of TempMode. Thank you in advance.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message