public static class GainsLift.GainsLiftBuilder extends MRTask<GainsLift.GainsLiftBuilder>
DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall
Constructor and Description |
---|
GainsLiftBuilder(double[] thresh) |
Modifier and Type | Method and Description |
---|---|
double |
avg_response_rate() |
double |
avg_score() |
double[] |
avg_scores() |
long[] |
events() |
void |
map(Chunk ca,
Chunk cp)
Override with your map implementation.
|
void |
map(Chunk ca,
Chunk cp,
Chunk cw)
Override with your map implementation.
|
long[] |
observations() |
void |
perRow(double pr,
int a,
double w) |
void |
postGlobal() |
void |
reduce(GainsLift.GainsLiftBuilder other)
Override to combine results from 'mrt' into 'this' MRTask.
|
double[] |
response_rates() |
appendables, asyncExecOnAllNodes, block, closeLocal, compute2, dfork, dfork, dfork, dfork, dfork, dinvoke, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAll, doAllNodes, getResult, getResult, isReleasable, map, map, map, map, map, map, map, map, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, profile, profString, self, setupLocal
copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException
asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON
__tryComplete, 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 final double[] response_rates()
public final double avg_response_rate()
public final double avg_score()
public final long[] events()
public final long[] observations()
public final double[] avg_scores()
public void map(Chunk ca, Chunk cp)
MRTask
map
in class MRTask<GainsLift.GainsLiftBuilder>
public void map(Chunk ca, Chunk cp, Chunk cw)
MRTask
map
in class MRTask<GainsLift.GainsLiftBuilder>
public void perRow(double pr, int a, double w)
public void reduce(GainsLift.GainsLiftBuilder other)
MRTask
reduce
in class MRTask<GainsLift.GainsLiftBuilder>
public void postGlobal()
postGlobal
in class MRTask<GainsLift.GainsLiftBuilder>