Hi Beam Users, For my future projects, I anticipate having to create pipelines having cycle(s).Could see some engines(Flink <https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/index.html#iterations> and Storm <https://groups.google.com/forum/#!topic/storm-user/EjN1hU58Q_8>) support this, they also provide flexibility to the user to ensure the loop ends for a given message by splitting & filtering streams. Could someone share any pointers to analogus of this in Beam Model? I did see that documentation <https://cloud.google.com/dataflow/java-sdk/JavaDoc/com/google/cloud/dataflow/sdk/Pipeline#class-pipeline> says Pipeline is always a DAG though.
Thanks, Eswar.
