Hi, I am trying to run a KMeansStreaming from the Java application, but it gives the following error:
"Getting java.lang.IllegalArgumentException: requirement failed while calling Sparks MLLIB StreamingKMeans from java application" Below is my code: JavaDStream<Vector> v = trainingData.map(new Function<String,Vector>() { public Vector call(String arg0) throws Exception { // TODO Auto-generated method stub String[] p = arg0.split(","); double[] d = new double[p.length] ; for(int i=0;i<p.length;i++) { d[i]=(Double.parseDouble(p[i])); } return Vectors.dense(d); } }); int numDimensions = 3; int numClusters = 2; StreamingKMeans model = new StreamingKMeans(); model.setK(numClusters); model.setDecayFactor(1); model.setRandomCenters(nnumDimensions, 0, 0); model.trainOn(trainingData.dstream()); --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org