Class MapRedFn

src/com/winvector/logistic/mr/MapRedFn.java:42–324

some hard-coded paths, so can not run two of these simultaneously @author johnmount

 *
 */
public final class MapRedFn implements VectorFn {
	private final Log log = LogFactory.getLog(MapRedFn.class);
	private static final String MRFIELDNAME = "MapRedFn.MRBlock";
	private final SigmoidLossMultinomial underlying;
	private final WritableVariableList defs;
	private final boolean useIntercept;
	private final Configuration mrConfig;
	private final Path pathIn;
	private final String tmpPrefix;

	
	public MapRedFn(final SigmoidLossMultinomial underlying, final WritableVariableList defs, final boolean useIntercept, 
			final String tmpPrefix, final Configuration mrConfig, final Path pathIn) {
		this.underlying = underlying;
		this.useIntercept = useIntercept;
		this.defs = defs;
		this.pathIn = pathIn;
		this.mrConfig = mrConfig;
		this.tmpPrefix = tmpPrefix;
	}
	
	@Override
	public int dim() {
		return underlying.dim();
	}

	public static final class JobStateDescr implements Writable {
		public SigmoidLossMultinomial underlying = null;
		public WritableVariableList defs = null;
		public boolean useIntercept = true;
		public String weightKey = null;
		public double[] x = null;
		public boolean wantGrad = false;
		public boolean wantHessian = false;
		
		@Override
		public void readFields(final DataInput in) throws IOException {
			underlying = null;
			defs = null;
			x = null;
			wantGrad = false;
			wantHessian = false;
			try {
				underlying = (SigmoidLossMultinomial)SerialUtils.readSerialiazlabeFromString(in.readUTF());
			} catch (ClassNotFoundException e) {
				throw new IOException(e.toString());
			}
			defs = new WritableVariableList();
			defs.readFields(in);
			useIntercept = in.readBoolean();
			final boolean haveWeightKey = in.readBoolean();
			if(haveWeightKey) {
				weightKey = in.readUTF();
			} else {
				weightKey = null;
			}
			x = WritableUtils.readVec(in);
			wantGrad = in.readBoolean();