Hi,
Here is my UDF that should build a VectorUDT. How do I actually make that the
value is in the vector?
package net.jgp.labs.spark.udf;
import org.apache.spark.mllib.linalg.VectorUDT;
import org.apache.spark.sql.api.java.UDF1;
public class VectorBuilder implements UDF1<Integer, VectorUDT> {
private static final long serialVersionUID = -2991355883253063841L;
@Override
public VectorUDT call(Integer t1) throws Exception {
return new VectorUDT();
}
}
i plan on having this used by a linear regression in ML...