Как передать параметр в задание потоковой передачи Python Hadoop?

Для потокового задания python Hadoop, как передать параметр, например, сценарию редуктора, чтобы он вел себя по-разному в зависимости от переданного параметра?

Я понимаю, что потоковые задания вызываются в формате:

hadoop jar hadoop-streaming.jar -input -output -mapper mapper.py -reducer reducer.py ...

Я хочу повлиять на reducer .py.