Resultados de la búsqueda a petición "scala"

1 la respuesta

gradle-android-scala-plugin da el error "No se pudo encontrar el constructor coincidente"

Importadoresta [https://github.com/saturday06/gradle-android-scala-plugin/tree/master/sample/hello] El código de ejemplo en Android Studio da este error: Error: (17, 0) No se pudo encontrar el constructor coincidente ...

1 la respuesta

Spark :: KMeans llama a takeSample () dos veces?

Tengo muchos datos y he experimentado con particiones de cardinalidad [20k, 200k +]. Yo lo llamo así: from pyspark.mllib.clustering import KMeans, KMeansModel C0 = KMeans.train(first, 8192, initializationMode='random', ...

1 la respuesta

Chispa: operación aleatoria que lleva a una larga pausa de GC

Estoy corriendoSpark 2 y estoy tratando de mezclar alrededor de 5 terabytes de json. Me encuentro con pausas muy largas de recolección de basura durante la mezcla de unDataset: val operations = ...

1 la respuesta

Java Spring como cliente para llamada HTTP REST basada en Akka

Tengo que llamar a este servicio REST escrito enscala-akka proyecto dejava-spring. mi servicio scala REST es como val route = post { path("notification" / "signUp"){ headerValueByName("App_Key") { app_key => { handleWith { requestParameters: ...

1 la respuesta

Cómo compilar / empaquetar el proyecto Spark 2.0 con jarras externas y Maven

Desde la versión 2.0, Apache Spark se incluye con una carpeta "frascos" llena de archivos .jar. Obviamente, Maven descargará todos estos frascos cuando emita: mvn -e packageporque para enviar una solicitud con spark-submit --class DataFetch ...

3 la respuesta

Spark SQL falla porque "El grupo constante ha superado el límite de JVM de 0xFFFF"

Estoy ejecutando este código en EMR 4.6.0 + Spark 1.6.1: val sqlContext = SQLContext.getOrCreate(sc) val inputRDD = sqlContext.read.json(input) try { inputRDD.filter("`first_field` is not null OR `second_field` is not ...

1 la respuesta

ClassTag.runtimeClass.isInstance no funciona para AnyVal

Al trabajar con Scala ClassTags, he visto que classTag.runtimeClass.isInstance no funciona correctamente cuando lo usas con objetos AnyVal. Aquí hay un fragmento donde puedes probarlo. ¿Alguna idea para hacer que esto funcione para los objetos ...

1 la respuesta

ID no enteros en Spark MLlib ALS

Me gustaria usar val ratings = data.map(_.split(',') match { case Array(user,item,rate) => Rating(user.toInt,item.toInt,rate.toFloat) }) val model = ALS.train(ratings,rank,numIterations,alpha)Sin embargo, los datos de usuario que obtengo se ...

6 la respuesta

Opción Scala [Futuro [T]] a Futuro [Opción [T]]

¿Cómo puedo convertirOption[Future[T]] aFuture[Option[T]] en scala? Quiero usarlo en: val customerAddresses = for { a <- addressDAO.insert(ca.address) // Future[Address] ia <- ca.invoiceAddress.map(addressDAO.insert) // Option[Future[Address]] ...

3 la respuesta

Scala: constructores curry

Tengo la siguiente clase Scala: class Person(var name : String, var age : Int, var email : String)Me gustaría usar el constructor de personas como una función curry: def mkPerson = (n : String) => (a : Int) => (e : String) => new ...