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.