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...

Reply via email to