datastream -> dataflow
added parallel Program class