Thanks Eugene...I see it in the packageĀ org.apache.beam.sdk.Ay code example on 
accurately using it pls?ThanksAmir-

      From: Eugene Kirpichov <>
 To: amir bahmanyari <>; "" 
 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 returns immediately.It 
returns a PipelineResult 
 which provides cancel() and other operations.
On Wed, Sep 21, 2016 at 5:03 PM amir bahmanyari <> wrote:

While still running [], 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-


Reply via email to