This won't work. You'd need to have the PipelineResult to construct your DoFn, but the PipelineResult is obviously unavailable until the whole pipeline is constructed and started.
I don't think there is a currently good way to cancel the pipeline from within the pipeline. Could you tell more about your use case - why do you need this? On Wed, Sep 21, 2016 at 5:54 PM amir bahmanyari <amirto...@yahoo.com> wrote: > Would work thanks. > Need to make some code changes so it becomes visible within the inner > class method processElement(). > Thanks very much Eugene. > > > ------------------------------ > *From:* Eugene Kirpichov <kirpic...@google.com> > *To:* amir bahmanyari <amirto...@yahoo.com>; " > user@beam.incubator.apache.org" <user@beam.incubator.apache.org> > *Sent:* Wednesday, September 21, 2016 5:25 PM > > *Subject:* Re: Graceful termination of pipeline at runtime > > Hmm, the straightforward way of invoking this API should work just fine: > > PipelineResult result = p.run(); > ...wait for your termination condition... > result.cancel(); > > Are you looking for something more specific? > > On Wed, Sep 21, 2016 at 5:17 PM amir bahmanyari <amirto...@yahoo.com> > wrote: > > Thanks Eugene...I see it in the package org.apache.beam.sdk. > Ay code example on accurately using it pls? > Thanks > Amir- > ------------------------------ > *From:* Eugene Kirpichov <kirpic...@google.com> > *To:* amir bahmanyari <amirto...@yahoo.com>; " > user@beam.incubator.apache.org" <user@beam.incubator.apache.org> > *Sent:* Wednesday, September 21, 2016 5:07 PM > *Subject:* Re: Graceful termination of pipeline at runtime > > You need to use a non-blocking runner where p.run() returns immediately. > It returns a PipelineResult ( > https://github.com/apache/incubator-beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/PipelineResult.java) > which provides cancel() and other operations. > > On Wed, Sep 21, 2016 at 5:03 PM amir bahmanyari <amirto...@yahoo.com> > wrote: > > While still running [p.run()], is there a way to terminate a pipleline p.x > based on a condition for instance? > I didnt see any related api like p.terminate() or similar... > Thanks > Amir- > > > > > >
