Hi Shen, No. Beam pipelines are DAGs: http://beam.incubator.apache.org/documentation/sdks/javadoc/0.3.0-incubating/org/apache/beam/sdk/Pipeline.html Best,
María On Tue, Nov 29, 2016 at 7:44 AM, Shen LI <cs.she...@gmail.com> wrote: > Hi, > > Can I use Beam to create a pipeline with cycles? For example, to implement > the Yahoo! Streaming benchmark( > https://yahooeng.tumblr.com/post/135321837876/benchmarking-streaming- > computation-engines-at), > can a ParDo transform consume a downstream output as a side input? > > Thanks, > > Shen >
