Apache beam example on Direct Runner. Apache beam is a unified dataflow model for creating pipeline that can run on different runners on local,spark cluster or google dataflow.