Not sure if that's what you were looking for, but check this out https://github.com/apache/incubator-beam/blob/master/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/RecordingPipelineVisitor.java
It's intended for internal unit tests but it's an example for a PipelineVisitor that traverses the constructed pipeline for inspection. On Fri, Mar 4, 2016 at 2:53 PM Minudika Malshan <[email protected]> wrote: > Hi all, > > I am looking forward to participate in gsoc 2016 with above mentioned > project. > Please support me to understand the implementation of following scenario. > > Suppose the user types the code written using data flow sdk commands in a > text box at the front end. > We need to get that code (let's say as a string) and execute at the back > end. > Does Data flow SDK provide a facility like a execution manager, to do such > a thing? > > Your help and comments are much appreciated. > > Thanks and regards > Minudika > > Minudika Malshan > Undergraduate > Department of Computer Science and Engineering > University of Moratuwa. >
