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 <[email protected]> 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- >
