Tag: scala

Bei der Verwendung von futures in scala die Vorgabe ist die Verwendung der Standard-Implicits.globalen Ausführungskontext. Es scheint, dies standardmäßig zu machen, ein thread pro Prozessor. In einer eher traditionellen threaded-web-Anwendung, dies scheint wie eine schlechte Standardeinstellung bei

Ich habe zwei Modelle (sagen, Lieferanten und Kaffee) und Kaffee-Modell hat die foreign-key-Referenz auf Lieferant Modell. Während ddl, dass ich diese Beziehung bestehen in der Erstellung der Tabelle. Aber ich möchte auch die Möglichkeit zu verweisen, die

Ich versuche zu berechnen Perzentil einer Spalte in einem DataFrame? Ich kann nicht finden, percentile_approx Funktion in der Funke-aggregation-Funktionen. Z.B. im Hive-wir haben percentile_approx und wir können es verwenden, in der folgenden Weise hiveContext.sql("select percentile_approx("Open_Rate",0.10) from myTable);

Was bedeutet [B >: A] bedeutet in Scala? Und was sind die Auswirkungen? Beispiel Referenz: http://www.scala-lang.org/node/129 class Stack[+A] { def push[B >: A](elem: B): Stack[B] = new Stack[B] { override def top: B = elem override def

Ich versuche zu installieren von scala auf meinem mac (Maverick). Ich heruntergeladen und entpackten es. Dann legte ich mich, von wo aus es wurde nicht archiviert und im /bin-Ordner in das terminal. Aber wenn ich "scala" oder

Gibt es keine built-in Funktion oder eine Methode von einer Liste, die es erlauben würde Benutzer hinzufügen ein neues element an einer bestimmten position einer Liste. Hab ich schrieb eine Funktion, die dies tut, aber ich bin

Ich habe den folgenden code in Spielen 2.0 Vorlage: @content.toString.lines.map{ case line => //i put `case` here as another attempt to make it work line match { case "" => @Html("") case _ => <li>@Html(line)</li> /*CRASH*/ }

So blenden Sie ein Textfeld in play framework? Zum Beispiel, wie dies zu verbergen Feld: @inputText(userProfileForm("name"), '_label -> "Name") InformationsquelleAutor Prasanth A R | 2013-06-04

Spark installieren, README,ich Schreibe den Befehl './bin/Funke-shell', Ich bekam einen Hinweis Folgendes: Gefunden, die mehrere Spark-Montage-jar-Dateien in /opt/Funke-0.9.0-bebrüten-bin-hadoop1/Montage/target/scala-2.10: spark-assembly-0.9.0-incubating-hadoop1.0.4.jar spark-assembly_2.10-0.9.0-incubating-hadoop1.0.4.jar Bitte entfernen Sie alle, aber eine jar. Ich immer versuchen, entfernen Sie einer von Ihnen ,aber ich

Habe ich folgende Daten : rowid uid time code 1 1 5 a 2 1 6 b 3 1 7 c 4 2 8 a 5 2 9 c 6 2 9 c 7 2 10 c

Ziehe ich meine ersten Schritte in Scala und ich möchte der folgende code funktioniert: trait Gene[+T] { val gene: Array[T] } Den Fehler, dass der compiler gibt ist: covariant type T occurs in invariant position in type

Ich habe einen code wie: val strs = List("hello", "andorra", "trab", "world") def f1(s: String) = !s.startsWith("a") def f2(s: String) = !s.endsWith("b") val result = strs.filter(f1).filter(f2) nun f1 und f2 angewendet werden soll, beruht auf einem Umstand,

mit Akka 2.0, die versuchen, eine Nachricht zu senden, um selbst (unter Verwendung der ask-Muster) import akka.pattern.ask import scala.concurrent.{Await, Future} import akka.actor.{Props, Actor, ActorSystem} import scala.concurrent.duration._ import akka.util.Timeout object askTest extends App{ implicit val timeout = Timeout(5

Hey ich will Funke in meinem Java-Projekt : Ich schon hinzufügen dieser Abhängigkeit in meiner pom-Datei : <dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-core_2.11</artifactId> <version>1.4.0</version> </dependency> Ich habe versucht, diesen code : import org.apache.spark.api.java.JavaSparkContext; public class sparkSQL { public void query()

Ich bin ein bisschen verwirrt darüber, Scala string split Verhalten, wie es nicht funktioniert, konsequent und Liste einige Elemente fehlen. Zum Beispiel, wenn ich eine CSV-Zeichenfolge mit 4 Spalten und 1 element fehlt. "elem1, elem2,,elem 4".split(",") =

Ich dachte, ich kann auf jede Methode, die von der Begleit-Klasse von meinem Begleiter-Objekt. Aber ich kann es nicht? class EFCriteriaType(tag:String) extends CriteriaType { //implemented method of CriteriaType def getTag = this.tag } object EFCriteriaType { var

Habe ich die folgenden Akka Schauspieler code in Scala. Code funktioniert gut, wenn eine einzelne workerActor erstellt. Aber code lautlos schlägt fehl, wenn ich versuchen, erstellen Sie einen pool von worker-Akteure mit round-robin-Logik. Irgendeine Idee, wie man

Ich nur ein Upgrade von der IDEE 12 bis 13 (community edition) und seitdem bekomme ich eine Fehlermeldung in der VORSTELLUNG über inkompatible Typen für meine Spiel-Projekt. Option<String> authHeaderOption = requestHeader.headers().get(AUTHORIZATION); requestHeader ist von Typ zu spielen.api.mvc.RequestHeader.

Ich versuche zu nennen, die runTask in meiner Aufgabe und als dieser funktionieren würde: name := "hello" version := "1.0" scalaVersion := "2.10.2" lazy val hello = taskKey[Unit]("executes hey") lazy val helloTask = hello <<= runTask(fullClasspath, "sample.Hey"

Habe ich eine Methode, die zurückgibt einen Future so... def isTokenExpired(token: String): Future[Boolean] = { ... } ... und dann hab ich eine andere Methode aufruft, die isTokenExpired gibt eine Boolean wie diese: def isExpired(token: String): Boolean

Kann ich verhindern, dass die Ausführung einer unendlichen Schleife in Scala REPL? Geben Sie diese und versuchen, ihn zu stoppen, ohne beenden der REPL. while(true){} Dachte ich, so etwas wie Strg-C funktionieren würde. Strg-C funktioniert bei mir

Wenn Sie eine Scala-Datei, die verwendet die Spark Dataset geben, bekomme ich folgenden stack trace: Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/spark/sql/Dataset at java.lang.Class.getDeclaredMethods0(Native Method) at java.lang.Class.privateGetDeclaredMethods(Class.java:2701) at java.lang.Class.privateGetMethodRecursive(Class.java:3048) at java.lang.Class.getMethod0(Class.java:3018) at java.lang.Class.getMethod(Class.java:1784) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:125) Caused by: java.lang.ClassNotFoundException:

Ich bin ziemlich neu im scala und Funken, und ich habe versucht, eine Lösung zu finden für dieses Problem den ganzen Tag - es tut meinem Kopf. Ich habe versucht 20 verschiedene Variationen des folgenden code und

Ich gerade aktualisiert, um die neuesten Scala-IDE version auf Eclipse, und es ist die Hervorhebung Lasten der unechten "illegale zyklische Vererbung" von Fehlern im code, ich weiß, OK zu sein (es war vor, und es noch kompiliert

Ist es möglich zu analysieren, eine String in eine FiniteDuration im Scala ohne benutzerdefinierten code schreiben zu müssen? Es ist eine Methode, die auf Duration genannt create, das akzeptiert eine String jedoch, dass erzeugt eine Duration und