Hi Minudika, The Beam SDK already supports running pipelines locally using the DirectPipelineRunner. To use this, set --runner=DirectPipelineRunner when you execute your pipeline. Currently, the DirectPipelineRunner only supports bounded inputs; support for unbounded is being tracked here: https://issues.apache.org/jira/browse/BEAM-22
Daniel On Wed, Mar 9, 2016 at 10:37 AM, Minudika Malshan <[email protected]> wrote: > Hi all, > > As per my knowledge about Apache beam and data flow sdk, at the first data > flow sdk has been developed targeting google cloud platform. > So we have to deploy pipelines in the cloud. > > But my question is, can not we use this sdk for standalone implementations > without cloud. If so, I would love to have a look at some examples of such > implementations. > Your kind help is much appreciated. > > Regards, > Minudika > > Minudika Malshan > Undergraduate > Department of Computer Science and Engineering > University of Moratuwa > Sri Lanka. >
