water.rapids.ast.prims.models

Class AstFairnessMetrics.FairnessMRTask

java.lang.Object

jsr166y.ForkJoinTask<java.lang.Void>

jsr166y.CountedCompleter

water.H2O.H2OCountedCompleter<T>

water.DTask<T>

water.MRTask

water.rapids.ast.prims.models.AstFairnessMetrics.FairnessMRTask

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, ForkJoinPool.ManagedBlocker, Freezable

Enclosing class:

AstFairnessMetrics

public static class AstFairnessMetrics.FairnessMRTask
extends MRTask

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.MRTask

MRTask.PostMapAction<T extends MRTask.PostMapAction<T>>

Nested classes/interfaces inherited from class water.DTask

DTask.DKeyTask<T extends DTask.DKeyTask,V extends Keyed>, DTask.RemoveCall

Field Summary

Fields

Modifier and Type	Field and Description
static double	FISHER_TEST_REL_ERROR
static int	GTEST_THRESHOLD

Fields inherited from class water.MRTask

_appendables, _fr, _fs, _hi, _keys, _left, _lo, _nhi, _nleft, _nlo, _nrite, _rite, _run_local, _topLocal

Fields inherited from class water.DTask

_ex

Constructor Summary

Constructors

Constructor and Description
FairnessMRTask(int[] protectedColsIdx, int[] cardinalities, int responseIdx, int predictionIdx, int favourableClass)

Method Summary

Modifier and Type	Method and Description
Frame	getMetrics(java.lang.String[] protectedCols, Frame fr, Model model, java.lang.String[] reference, java.lang.String frName)
java.util.Map<java.lang.String,Frame>	getROCInfo(Model model, Frame fr, java.lang.String frName)
protected java.lang.String	keyToString(int value, Frame fr)
void	map(Chunk[] cs) Override with your map implementation.
int	pColsToKey(int[] indices)
void	reduce(MRTask mrt) Override to combine results from 'mrt' into 'this' MRTask.

Methods inherited from class water.MRTask

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, map, map, modifiesVolatileVecs, onCompletion, onExceptionalCompletion, outputFrame, outputFrame, outputFrame, postGlobal, profile, profString, self, setupLocal, withPostMapAction

Methods inherited from class water.DTask

copyOver, getDException, hasException, logVerbose, onAck, onAckAck, setException

Methods inherited from class water.H2O.H2OCountedCompleter

asBytes, clone, compute, compute1, currThrPriority, frozenType, icer, priority, read, readJSON, reloadFromBytes, write, writeJSON

Methods inherited from class jsr166y.CountedCompleter

__tryComplete, addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete

Methods inherited from class jsr166y.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, 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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

GTEST_THRESHOLD

public static final int GTEST_THRESHOLD

See Also:

Constant Field Values

FISHER_TEST_REL_ERROR

public static final double FISHER_TEST_REL_ERROR

See Also:

Constant Field Values

Constructor Detail

FairnessMRTask

public FairnessMRTask(int[] protectedColsIdx,
                      int[] cardinalities,
                      int responseIdx,
                      int predictionIdx,
                      int favourableClass)

Method Detail

pColsToKey

public int pColsToKey(int[] indices)

keyToString

protected java.lang.String keyToString(int value,
                                       Frame fr)

map

public void map(Chunk[] cs)

Description copied from class: MRTask

Override with your map implementation. This overload is given an array of local input Chunks, for Frames with arbitrary column numbers. All map variants are called, but only one is expected to be overridden.

Overrides:

map in class MRTask

reduce

public void reduce(MRTask mrt)

Description copied from class: MRTask

Override to combine results from 'mrt' into 'this' MRTask. Both 'this' and 'mrt' are guaranteed to either have map() run on them, or be the results of a prior reduce(). Reduce is optional if, e.g., the result is some output vector.

Overrides:

reduce in class MRTask

getMetrics

public Frame getMetrics(java.lang.String[] protectedCols,
                        Frame fr,
                        Model model,
                        java.lang.String[] reference,
                        java.lang.String frName)

getROCInfo

public java.util.Map<java.lang.String,Frame> getROCInfo(Model model,
                                                        Frame fr,
                                                        java.lang.String frName)