python mycode.py \
--project [PROJECT_ID] \
--setup_file ./setup.py \
--temp_location [TEMP_GCS_LOCATION] \
--runner DataflowRunner
Please feel free to use this library in commercial purposes as this is meant for open source
pip install git+https://github.com/pavan-kattamuri/dataflow_joins#egg=my_package