:py:class:`~mrjob.fs.base.Filesystem` object for SSH, S3, and the local filesystem.

:py:class:`~mrjob.fs.base.Filesystem` object for SSH, S3, GCS, and the local filesystem.

Yield the names of all buckets associated with this client. :param prefix: optional prefix to search under (e.g. ``'mrjob-'``) .. ve

Get the version that our cluster is running.

Get options set for this runner, as a dict.

Implements hadoop fs <args>

Implements hadoop fs -cat <src>

Implements hadoop fs -dus.

Implements hadoop fs -ls.

Implements hadoop fs -lsr.

Implements hadoop fs -mkdir

Implements hadoop fs -put

Implements hadoop fs -rm.

Implements hadoop fs -test.

Implements hadoop fs -touchz

Parse stop_words option.

Recursively yield the URIs of S3 keys matching the given glob. *path_glob* can include ``?`` to match single characters or ``*`` to m

Tokenize lines, and look for pairs of adjacent words. Yield (prev_word, word), 1 and (prev_word, '*'), 1 for each pair

Makes a pooled cluster and returns its cluster ID. Set ``cluster.startdatetime`` to *minutes_ago* before ``datetime.datetime.now()``.

create a dummy job, and call make_runner() on it. Use this in a with block: with self.make_runner() as runner: ...

Re-define this to define the mapper for a one-step job. Yields zero or more tuples of ``(out_key, out_value)``. :param key: A value

For each log line, with probability self.sampling_probability, yield a None key, and (random seed, line) as the value, so that