Thanks Eugene...I see it in the package org.apache.beam.sdk.Ay code example on
accurately using it pls?ThanksAmir-
From: Eugene Kirpichov <kirpic...@google.com>
To: amir bahmanyari <amirto...@yahoo.com>; "email@example.com"
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
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...ThanksAmir-