Description Usage Arguments Details Value See Also Examples
Helper function to construct R structure describing a Map
task. To be used to satisfy the ...
argument of
mantaJob.setup
and specify the Unix command
line task, any initialization tasks, an array of Manta
asset
objects, and the memory/disk size to be used
for the compute instance on Manta.
1 | mantaMap(exec, init, assets, memory, disk)
|
exec |
character required. The Unix shell command to
be executed in the Map task operating on the input Manta
objects specified when the job is launched. |
init |
character optional. A Unix shell command
executed prior to the |
assets |
array of character, optional. Specify Manta
objects that are to be accessed by the compute node at
job runtime. Include shell scripts, installation steps
configuration steps, custom executables compiled for
SmartOS, or |
memory |
integer optional. Amount of memory
requested for Manta compute node instance. |
disk |
integer optional. Amount of temporary working
disk (not Manta storage space) to be used by the compute
node when executing the task. Valid values are: |
On Manta, a Map task phase executes a generic UNIX command
given some input Manta object list which is specified in
mantaJob.launch
, which distributes the jobs to
compute instances local to the Manta object location. The
exec
argument must be a valid generic UNIX command
line, not an R function. The exec
argument may call
executables or runtime language scripts that are hosted on
Manta and specified as assets
. The init
argument is called before the exec argument and is not
passed input. The init argument may be used, for example to
extract scripts from an asset
on Manta saved as a
tar
file.
Returns an R list describing a Map task phase for
consumption by mantaJob.setup
Other mantaJobs: mantaJob.cancel
;
mantaJob.done
;
mantaJob.errors.stderr
;
mantaJob.errors
;
mantaJob.failures
;
mantaJob.inputs
;
mantaJob.launch
;
mantaJob.outputs.cat
;
mantaJob.outputs
;
mantaJob.setup
;
mantaJob.status
;
mantaJobs.running
;
mantaJobs.tail
; mantaJobs
;
mantaReduce
1 2 3 4 5 6 7 | ## Not run:
# Example - Map/Reduce Unix Word Count
job <- mantaJob.setup("word count",
mantaMap("wc"),
mantaReduce("awk '{ l += $1; w += $2; c += $3 } END { print l, w, c }'"))
## End(Not run)
|
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.