akka

1Hitze

1Antwort

akka Schauspieler Generika erhalten Methode

Ich habe eine Klasse implementiert, die allgemeine Parameter für eine Funktion übernimmt, sieht die funtion Signatur wie def getPreparedStatement[T >: AnyVal](messagesForHBase: MessagesForHBase[T]):Li

0Hitze

1Antwort

Verwendung von Akka Dispatchern für die Handhabung von Futures

Ich habe einen Spray-basierten HTTP-Service. Ich habe einen Stream, der innerhalb dieser HTTP-Anwendung läuft. Da dieser Stream viele I/O-Vorgänge ausführt, entschied ich mich für einen separaten Thre

7Hitze

2Antwort

Unterschied zwischen transparenten Remoting- und Standorttransparenz

Ich habe ein wenig gegoogelt eine gute Erklärung für die Differenz zwischen den beiden oben genannten Strategien Remote zu finden, das heißt transparente Remote und Standorttransparenz. Soweit ich wei

1Hitze

1Antwort

Scala/akka diskrete Ereignissimulation

Ich erwäge, eine große Codebasis zu Scala zu migrieren und das Akka Actor Modell zu nutzen. Ich stoße fast sofort auf folgendes konzeptionelles Problem: In der vorhandenen Codebasis wird Geschäftslogi

1Hitze

1Antwort

Wie man einen gepufferten tcp Publisher/Subscriber in scala erstellt playframework/akka

Wir sind dabei, von einer Python-basierten Umgebung zu scala play framework one zu wechseln und einen gepufferten Publisher-Subscriber zu schreiben, der mit einem anderen System interagiert geschriebe

1Hitze

1Antwort

Akka ActorSelection über einen ganzen Cluser

Ich habe einen einfachen Cluster mit einem Dienstakteur namens "Service" auf jedem Knoten. Dieser Service ist jeweils mit ClusterClientRecptionist exponiert, um ihn von außerhalb des Clusters mit Clus

0Hitze

1Antwort

Kann das LDA-Modell nicht in Spark gespeichert werden?

Ich versuche, LDA auszuführen. ldaModel = (DistributedLDAModel) new LDA().setK(numTopics).setMaxIterations(1).run(corpus); ldaModel.save(Main.sc.sc(), saveLDAPath); bis jetzt alles funktioniert jed

4Hitze

2Antwort

Scala/Akka Syntax

Ich bin neu in Scala und Akka und habe this Tutorial gefolgt. Ich bin auf folgendes gestoßen und habe mich gefragt, was genau diese Syntax bedeutet? import akka.actor.Props val props1 = Props[MyActo

0Hitze

1Antwort

Akka HTTP-Fluss wird nicht gestoppt, wenn Ausnahme ausgelöst wird

Ich versuche, Akka HTTP für das POST auf einem Webserver zu verwenden. Wenn ein POST fehlschlägt, möchte ich, dass es aufhört und nicht mehr POSTs sendet, da sie nicht idempotent sind. Der folgende Co

6Hitze

1Antwort

akka-stream - So behandeln Sie das letzte Element eines Streams anders in einem Flow/Graph

Ich versuche einen Akka Stream Flow zu implementieren, der einen Stream von JSON-Objekten in einen Stream eines einzelnen Arrays von JSON-Objekten konvertiert . Ich kann Concat verwenden, um ein "[" v