Hi Amir, If you’re looking for a runner-independent example, you can find some in examples/.
If you’re looking for runner-independent code that works on Flink, I think you should still wait a few iterations. Or, you can take code that refers to Flink, and remove the dependencies yourself. For instance, if you start from this example: https://github.com/ecesena/beam-starter/blob/master/src/main/java/com/dataradiant/beam/examples/WordCount.java You can remove the setRunner by passing -Drunner=FlinkRunner in pom.xml You can remove FlinkPipelineOptions but you have to implement yourself some of the getter/setter required by Flink, e.g. jobName: https://github.com/apache/incubator-beam/blob/master/runners/flink/runner/src/main/java/org/apache/beam/runners/flink/FlinkPipelineOptions.java Hope this helps, > On Jul 25, 2016, at 2:59 PM, amir bahmanyari <[email protected]> wrote: > > Hi Colleagues, > Is there a simple genetic example where the Runner is passed at the command > line, the Beam code sets it in the generic Beam Options.set Runner(), and > Pipeline.create() is? > No mention of ANY specific Runner in the code like FlinkPipelineOptions . > > Thanks. > Amir- -- Emanuele Cesena, Data Eng. http://www.shopkick.com Il corpo non ha ideali
