/hadoop/cacheArchive/
../
input
mapper.py
my_module.zip
my_module
other_module.zip
other_module
output
streaming.sh