let distributed_shell_program
?(hadoop_bin="hadoop")
?(distributed_shell_shell_jar=default_distributed_shell_jar)
~container_memory
~timeout
~application_name
program =
`Distributed_shell (
{hadoop_bin; distributed_shell_shell_jar;
container_memory; timeout; application_name}, program)