public class FileIntegrityChecker extends MRTask<FileIntegrityChecker>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
_appendables, _fr, _fs, _hi, _keys, _left, _lo, _nhi, _nleft, _nrite, _nxx, _rite, _topLocal
_ex, _modifiesInputs
Constructor and Description |
---|
FileIntegrityChecker(java.io.File root) |
Modifier and Type | Method and Description |
---|---|
static FileIntegrityChecker |
check(java.io.File r) |
byte |
priority() |
void |
reduce(FileIntegrityChecker o)
Override to combine results from 'mrt' into 'this' MRTask.
|
void |
setupLocal()
Override to do any remote initialization on the 1st remote instance of
this object, for initializing node-local shared data structures.
|
int |
size() |
Key |
syncDirectory(java.util.ArrayList<java.lang.String> files,
java.util.ArrayList<java.lang.String> keys,
java.util.ArrayList<java.lang.String> fails,
java.util.ArrayList<java.lang.String> dels) |
appendables, asyncExec, asyncExec, asyncExec, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, isReleasable, map, map, map, map, map, map, map, map, map, map, map, map, map, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, outputFrame, postGlobal, profString, setProfile
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
clone, compute, frozenType, icer, nextThrPriority, read_impl, read, readJSON_impl, readJSON, write_impl, write, writeHTML_impl, writeHTML, writeJSON_impl, writeJSON
addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete
adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork
public void setupLocal()
MRTask
setupLocal
in class MRTask<FileIntegrityChecker>
public void reduce(FileIntegrityChecker o)
MRTask
reduce
in class MRTask<FileIntegrityChecker>
public byte priority()
priority
in class MRTask<FileIntegrityChecker>
public static FileIntegrityChecker check(java.io.File r)
public int size()
public Key syncDirectory(java.util.ArrayList<java.lang.String> files, java.util.ArrayList<java.lang.String> keys, java.util.ArrayList<java.lang.String> fails, java.util.ArrayList<java.lang.String> dels)