Re: Send JsonDocument to Couchbase

anyone ? I know that there isn't much experience yet with Couchbase connector On Tue, Dec 1, 2015 at 4:12 PM, Eyal Sharon wrote: > Hi , > > I am still having problems with Couchbase connector . Consider the > following code fragment which aims to create a Json document t

Send JsonDocument to Couchbase

Hi , I am still having problems with Couchbase connector . Consider the following code fragment which aims to create a Json document to send to Couch *val muCache = { val values = JsonArray.from(mu.toArray.map(_.toString)) val content = JsonObject.create().put("feature_mean", values).put("

Re: Help with type check

' > > You might want to have a look at these too: > - > http://stackoverflow.com/questions/23821576/efficient-conversion-of-java-util-listjava-lang-double-to-scala-listdouble > - https://docs.oracle.com/javase/7/docs/api/java/lang/Double.html > - http://www.scala-lang.org/api/c

Help with type check

Hi , I have problem with inferring what are the types bug here I have this code fragment . it parse Json to Array[Double] *val muCouch = { val e = input.filter( _.id=="mu")(0).content() val b = e.getArray("feature_mean") for (i <- 0 to e.getInt("features") ) yield b.getDouble(i)}.toArra

Re: Help with Couchbase connector error

sion-used-to-compile-a-class-file >> >> On Thu, Nov 26, 2015 at 8:55 AM, Eyal Sharon wrote: >> >>> Hi , >>> Great , that gave some directions. But can you elaborate more? or share >>> some post >>> I am currently running JDK 7 , and my Couchbas

Re: Help with Couchbase connector error

untime. > > When building, target JDK 1.7 > > There're plenty of posts on the web for dealing with such error. > > Cheers > > On Thu, Nov 26, 2015 at 7:31 AM, Eyal Sharon wrote: > >> Hi, >> >> I am trying to set a connection to Couchbase. I am at th

Help with Couchbase connector error

Hi, I am trying to set a connection to Couchbase. I am at the very beginning, and I got stuck on this exception Exception in thread "main" java.lang.UnsupportedClassVersionError: com/couchbase/spark/StoreMode : Unsupported major.minor version 52.0 Here is the simple code fragment val sc =

Help with serialization

Hi All, I'm running a streaming application, the application should send an output to an external source This piece of code send the Dstream to graphite. streamDataRow.foreachRDD { rdd => rdd.foreachPartition { partitionOfRecords => val graphite = new GraphiteClient(new InetSocketAddress

Problem with applying Multivariate Gaussian Model

Hi , I have been trying to apply an Anomaly Detection model using Spark MLib. I am using this library org.apache.spark.mllib.stat.distribution.MultivariateGaussian As an input, I give the model a mean vector and a Covariance matrix, assuming my features have Covariance , hence the covariane