package water.rapids;

import hex.quantile.Quantile;
import hex.quantile.QuantileModel;
import water.DKV;
import water.fvec.Frame;
import water.fvec.Vec;

/**
 * Quantiles: 
 *  (quantile %frame [numnber_list_probs] "string_interpolation_type")
 */
class ASTQtile extends ASTPrim {
  @Override
  public String[] args() { return new String[]{"ary", "probs", "interpolationMethod", "weights_column"}; }
  @Override int nargs() { return 1+4; }
  @Override
  public String str() { return "quantile"; }
  @Override Val apply( Env env, Env.StackHelp stk, AST asts[] ) {
    QuantileModel.QuantileParameters parms = new QuantileModel.QuantileParameters();
    Frame fr = stk.track(asts[1].exec(env)).getFrame();
    Frame fr_wkey = new Frame(fr); // Force a bogus Key for Quantiles ModelBuilder
    DKV.put(fr_wkey);
    parms._train = fr_wkey._key;

    parms._probs = ((ASTNumList)asts[2]).expand();
    for( double d : parms._probs )
      if( d < 0 || d > 1 ) throw new IllegalArgumentException("Probability must be between 0 and 1: "+d);

    String inter = asts[3].exec(env).getStr();
    parms._combine_method = QuantileModel.CombineMethod.valueOf(inter.toUpperCase());
    parms._weights_column = asts[4].str().equals("_") ? null : asts[4].str();

    // Compute Quantiles
    QuantileModel q = new Quantile(parms).trainModel().get();

    // Remove bogus Key
    DKV.remove(fr_wkey._key);

    // Reshape all outputs as a Frame, with probs in col 0 and the
    // quantiles in cols 1 thru fr.numCols() - except the optional weights vec
    int ncols = fr.numCols();
    if (parms._weights_column != null) ncols--;
    Vec[] vecs = new Vec[1 /*1 more for the probs themselves*/ + ncols];
    String[] names = new String[vecs.length];
    vecs [0] = Vec.makeCon(null,parms._probs);
    names[0] = "Probs";
    int w=0;
    for( int i=0; i<vecs.length-1; ++i ) {
      if (fr._names[i].equals(parms._weights_column)) w=1;
      assert(w==0 || w==1);
      vecs [i+1] = Vec.makeCon(null,q._output._quantiles[i]);
      names[i+1] = fr._names[w+i]+"Quantiles";
    }
    q.delete();

    return new ValFrame(new Frame(names,vecs));
  }
}


@@ -99,16 +99,34 @@
 er.DKV;%0A
+import water.Job;%0A
 import w
@@ -1293,23 +1293,13 @@
     
-QuantileModel q
+Job j
  = n
@@ -1333,13 +1333,77 @@
 el()
-.get(
+;%0A    QuantileModel q = (QuantileModel)j.get();%0A    DKV.remove(j._key
 );%0A%0A

Fix PUBDEV-2642: No longer flood Jobs list with Rapids' Quantiles.