pipelines/samples/core/parallel_join
..
parallel_join.py