the mrjob package and its subpackage, in sorted order

Read the next set of counters from the filesystem, and delete it. If no counters available, return {}

Uploads a local file to a specific destination. .. versionchanged:: 0.7.0 removed *chunk_size* arg (use *part_size* in

Mock SSH behavior for uploading SSH key with sh -c "cat ..."

Execute a command as a "host." Recursively call for worker if necessary.

Run the combiner for the given step. :type step_num: int :param step_num: which step to run (0-indexed) If we encounter a li

Run the all steps of the job, logging errors (and debugging output if :option:`--verbose` is specified) to STDERR and streaming the ou

Run the Spark code for the given step. :type step_num: int :param step_num: which step to run (0-indexed) Called from :py:me

Redefine this to pass custom arguments to Spark.

put *number* in a standard format, and convert it to a :py:class:`str`.

Recursively convert lists to tuples. This only looks into lists, which seems to be good enough for testing

Compress the given *dir* into a zip file at *out_path*. If we encounter symlinks, include the actual file, not the symlink. :type dir: str

Don't do anything special at start of with block

Call self.cleanup() at end of with block.

The glue that makes functions retriable, and returns other attributes from the wrapped object as-is.

:py:class:`~mrjob.inline.InlineMRJobRunner` takes the same keyword args as :py:class:`~mrjob.runner.MRJobRunner`. However, please note

:py:class:`~mrjob.hadoop.HadoopJobRunner` takes the same arguments as :py:class:`~mrjob.runner.MRJobRunner`, plus some additional options

Initialize a reason for step failure. :param string reason: brief explanation of which step failed :param int step_num: which step fa