|
KMR
|
KMR-Shell Job-Script Generator. More...
Go to the source code of this file.
Functions | |
| def | kmrgenscript.checkdir (path, force) |
| Checks path is a directory. More... | |
| def | kmrgenscript.checkexist (path) |
| Checks file existence. More... | |
| def | kmrgenscript.k_scheduler (node, infile, outfile, indir, outdir, rsctime, mapper, reducer, multi, scrfile) |
| Generates job-script for K. More... | |
| def | kmrgenscript.selectscheduler (node, infile, outfile, indir, outdir, rsctime, mapper, reducer, multi, sched, scrfile) |
| Selects job-scheduler. More... | |
Variables | |
| kmrgenscript.action | |
| kmrgenscript.args | |
| kmrgenscript.default | |
| kmrgenscript.dest | |
| kmrgenscript.files = os.listdir(options.indir) | |
| kmrgenscript.help | |
| string | kmrgenscript.kmrhome = '@KMRHOME@' |
| kmrgenscript.metavar | |
| kmrgenscript.options | |
| kmrgenscript.parser = OptionParser(usage) | |
| kmrgenscript.type | |
| string | kmrgenscript.usage = "usage: %prog [options] -m mapper [-r reducer]" |
| kmrgenscript main routine. More... | |
KMR-Shell Job-Script Generator.
Definition in file kmrgenscript.in.py.
| def kmrgenscript.checkexist | ( | path | ) |
Checks file existence.
If file does not exist, it prints an error message and exit.
| path | file path for check. |
Definition at line 16 of file kmrgenscript.in.py.
| def kmrgenscript.checkdir | ( | path, | |
| force | |||
| ) |
Checks path is a directory.
If path does not exist, it prints an error message and exit. Or, it creates a directory with force option.
Definition at line 25 of file kmrgenscript.in.py.
| def kmrgenscript.k_scheduler | ( | node, | |
| infile, | |||
| outfile, | |||
| indir, | |||
| outdir, | |||
| rsctime, | |||
| mapper, | |||
| reducer, | |||
| multi, | |||
| scrfile | |||
| ) |
Generates job-script for K.
| node | number of node to execute. |
| infile | input file pathname. |
| outfile | output file prefix. |
| indir | directory path name that has input files. |
| outdir | directory path name that has result output files. |
| rsctime | resource time limit. |
| mapper | pathname of mapper program. |
| reducer | pathname of reducer program. |
| multi | multiple input file for one mapper process. |
| scrfile | output script file name. |
Definition at line 53 of file kmrgenscript.in.py.
| def kmrgenscript.selectscheduler | ( | node, | |
| infile, | |||
| outfile, | |||
| indir, | |||
| outdir, | |||
| rsctime, | |||
| mapper, | |||
| reducer, | |||
| multi, | |||
| sched, | |||
| scrfile | |||
| ) |
Selects job-scheduler.
| node | number of node to execute. |
| infile | input file pathname. |
| outfile | output file prefix. |
| indir | directory path name that has input files. |
| outdir | directory path name that has result output files. |
| rsctime | resource time limit. |
| mapper | pathname of mapper program. |
| reducer | pathname of reducer program. |
| multi | multiple input file for one mapper process. |
| sched | scheduler. |
| scrfile | output script file name. |
Definition at line 148 of file kmrgenscript.in.py.
| string kmrgenscript.usage = "usage: %prog [options] -m mapper [-r reducer]" |
kmrgenscript main routine.
It works on Python 2.4 or later.
Definition at line 158 of file kmrgenscript.in.py.
1.8.11