public static class KMeansModel.KMeansScore extends MRTask
Modifier and Type | Field and Description |
---|---|
double[] |
_dist |
long[] |
_rows |
_hi, _lo, _runSingleThreaded
_fs, _is_local, _keys, _top_level
_cls, _eFromNode, _exception, _fname, _lineNum, _msg, _mth
Constructor and Description |
---|
KMeansModel.KMeansScore() |
Modifier and Type | Method and Description |
---|---|
void |
map(Key key)
Run some useful function over this local key, and
record the results in the this MRTask.
|
void |
reduce(DRemoteTask rt) |
static KMeansModel.KMeansScore |
score(KMeansModel model,
ValueArray ary) |
com.google.gson.JsonObject |
toJson() |
hi, init, lcompute, lo, lonCompletion, memOverheadPerChunk, onExceptionalCompletion
alsoBlockFor, alsoBlockFor, block, clone, compute2, dfork, getFutures, invoke, invokeOnAllNodes, isReleasable, keys, onCompletion, postGlobal, reduceAlsoBlock
copyOver, dinvoke, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, read, setException, toDocField, write, writeJSONFields
compute, priority
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 static KMeansModel.KMeansScore score(KMeansModel model, ValueArray ary)
public void map(Key key)
MRTask
public void reduce(DRemoteTask rt)
reduce
in class DRemoteTask
public com.google.gson.JsonObject toJson()