Tag: scala

Scala ist eine Allzweck-Programmiersprache, die grundsätzlich Ausrichtung der Java Virtual Machine. Entwickelt, um express-common programming patterns in einer prägnant, elegant und typsicher Weise, es verschmilzt die beiden imperative und funktionale Programmierung-Stile. Seine Hauptmerkmale sind:
erweiterte statische Typ-system mit Typ-Inferenz ist;
Funktion Typen; pattern-matching; implizite Parameter und Umbauten; operator überladen; die volle Interoperabilität mit Java; Parallelität

Scala pattern match Standard-Wachen

3 Antworten

Ich will viele case-Anweisungen mit gleichen Wache vor jeder. Kann ich es tun in einer Weise, erfordert keine code-Duplizierung ? "something" match { case "a" if(variable) => println("a") case "b" if(variable) => println("b") //... } können Sie

pattern-matching scala

Scala verschachtelten Schleifen Rendite

2 Antworten

Ich Frage mich, ob es eine einfache Möglichkeit, etwas zu tun, wie dies in scala: case class Pot(width: Int, height: Int, flowers: Seq[FlowerInPot]) case class FlowerInPot(x: Int, y: Int, flower: String) val flowers = Seq("tulip", "rose") val

Durchlaufen Mitglieder von collection in Scala

6 Antworten

Was ist ein effizienter Weg, um zu Durchlaufen und nur die Mitglieder einer collection in Scala, basierend auf index-position? Angesichts dieser Liste: val fruits: List[String] = List("apples", "oranges", "pears", "bananas") Möchte ich überspringen, äpfel und Birnen, und

scala scala-collections

Wie kann ich die Iteration einer Liste von Listen in Scala?

3 Antworten

Bin ich zu versuchen, meine eigene generische glätten für list-Objekte, welche die CSG-Listen in Scala. An diesem Punkt habe ich def myFlatten[T](list: List[List[t]]): List[T] = { for (xs <- list) for (x <- xs) yield x }

generics list scala

Spark ' s Spalte.isin-Funktion nicht Liste

2 Antworten

Ich versuche heraus zu filtern und Zeilen aus meinem Spark Dataframe. val sequence = Seq(1,2,3,4,5) df.filter(df("column").isin(sequence)) Leider bekomme ich eine nicht unterstützte literal-Typ-Fehler java.lang.RuntimeException: Unsupported literal type class scala.collection.immutable.$colon$colon List(1,2,3,4,5) entsprechend der Dokumentation dauert es eine scala.Sammlung.Seq

apache-spark java scala

na.füllen Sie Funken DataFrame Scala

1 Antworten

Bin ich mit Spark/Scala, und ich will füllen die Nullen in meinem DataFrame mit default-Werte basierend auf dem Typ der Spalten. ich.e-Saite Spalten -> "string", " Numeric-Spalten -> 111 -, Boolean-Spalten -> False, etc. Derzeit die DF.na.Funktionen-API

apache-spark dataframe scala

Spark: How to map Python mit Scala oder Java-User Defined Functions?

1 Antworten

Lassen Sie uns sagen zum Beispiel, dass mein team ausgewählt hat Python als Referenz Sprache zu entwickeln, mit Funke. Aber später aus Gründen der Leistung, die wir entwickeln möchten, bestimmte Scala oder Java-spezifische Bibliotheken, um die Karte

apache-spark java pyspark python scala

Funke: coalesce sehr langsam, auch die Datenausgabe ist sehr klein

1 Antworten

Ich habe den folgenden code in Spark: myData.filter(t => t.getMyEnum() == null) .map(t => t.toString) .saveAsTextFile("myOutput") Gibt es 2000+ Dateien in der myOutput", aber nur ein paar t.getMyEnum() == null, so gibt es nur sehr wenige output

apache-spark coalesce scala

Set default-Wert für die Funktion parameter im scala

3 Antworten

Ich bin versucht, einen default-Wert eine anonyme Funktion in scala, und damit nicht in der Lage zu finden keine Lösung. Hoffe jemand würde mir helfen in SO. Habe ich die folgende Struktur, case class A(id:Int = 0)

lambda scala

drucken Typ der Variablen in Scala

1 Antworten

Gibt es eine saubere Methode print der Klasse name einer Variablen in Scala? Manchmal sehe ich val result = foo(a,b,c), da die Methode foo zurückkehren können verschiedene Typen von Objekten, und wenn ich drucken konnte, Klasse, Art

scala

Nachteile von Scala-Typsystem vs. Haskell?

6 Antworten

Habe ich gelesen, dass Scala ' s Typsystem ist geschwächt durch Java-Interoperabilität und kann daher nicht ausführen einige der die gleichen Befugnisse wie Haskell Typ-system. Ist das wahr? Ist die Schwäche, denn der Typ Löschung, oder bin

haskell language-comparisons scala static-typing type-systems

Joda Time: Konvertieren von UTC in die lokale

1 Antworten

Ich umwandeln möchten, Joda Time UTC-DateTime-Objekt nach lokaler Zeit. Hier ist ein mühsamer Weg, es zu tun, die scheint zu funktionieren. Aber es muss einen besseren Weg geben. Hier ist der code (in der Scala) ohne umgebende

jodatime local scala time utc

Wie, um die Anzahl der zu verwendenden threads für par

2 Antworten

Ich kennen, dass Sie können die Anzahl der zu verwendenden threads für alle .par-Operationen wie so: collection.parallel.ForkJoinTasks.defaultForkJoinPool.setParallelism(parlevel: Int) Aber ist es möglich, die Anzahl der zu verwendenden threads für nur eine .par nennen? Ich nehme an, man

parallel-processing scala

Bootstrapping ein web-server in Scala

8 Antworten

Den folgenden ist möglich mit Python: $ apt-get install python $ easy_install Flask $ cat > hello.py from flask import Flask app = Flask(__name__) @app.route("/") def hello(): return "Hello World!" if __name__ == "__main__": app.run() $ python

python scala

Wie zu tun-aggregation über mehrere Spalten auf einmal in der Funke

1 Antworten

Ich habe einen dataframe, die hat mehrere Spalten. Ich möchte die Gruppe von einer der Spalten-und aggregate anderen Spalten alle einmal. Angenommen, die Tabelle hat 4 Spalten cust_id, f1,f2,f3, und ich will group by cust_id und dann

apache-spark scala

Wenn Hystrix Kurzschluss und die Schaltung ist OFFEN, es ist nie geschlossen, auch nachdem der der säumige service wieder verfügbar ist

1 Antworten

Ich habe ein Problem, wo, wenn die hystrix Schutzschalter ausgelöst wird, es nicht zu schließen, immer und immer wieder. Ich habe aktiviert die Protokollierung auf debug-und ich sehe nicht, versucht es zu ermöglichen, eine test-Anfrage durch, in

akka hystrix java scala

Lesung im HDF5-Dateien in Apache Spark

3 Antworten

Gibt es eine Möglichkeit, Lesen Sie im HDF5-Dateien mit der Scala-version von Spark? Es sieht aus wie es getan werden kann in Python (über Pyspark), aber ich kann nichts finden für Scala. Dies könnte Ihnen helfen, loszulegen.

apache-spark hdf5 scala

Scala: Entfernen Sie das Letzte vorkommen eines Zeichens

3 Antworten

Ich versuche zu entfernen, das Letzte vorkommen eines Zeichens in einem string. Ich kann seine index: str.lastIndexOf(',') Habe ich bereits versucht zu verwenden split und die replace - Funktion auf den string. Können Sie versuchen, diese :

indexing scala string

macht einen GET-request an einen webservice aus dem playframework 2.0

3 Antworten

Ich versuche zu nennen, einen webservice aus dem play framework, und ich denke, ich mache es falsch. Ich habe ein Beispiel-Aufruf http://www.myweather2.com/developer/forecast.ashx?uac=eDKGlpcBQN&query=52.6%2C-4.4&output=xml Einen Ausschnitt von dem, was ich bin versucht aus dem playframework ist folgende: val response

playframework playframework-2.0 scala webrequest

Scala-Liste.diff .schneiden und .union funktioniert nicht wie erwartet

4 Antworten

Mithilfe der unten aufgeführte code ergibt die folgende: List(a, b) List() List(a, b, b, c) Was ich will, ist natürlich ein Ergebnis wie dieses: List(a) List(b) List(a, b, b, c) Ich denke, das ist, weil die diff-union-und

scala

Wie kann ich mich verwandeln eine Karte, die zu einem Fall der Klasse in Scala?

5 Antworten

Wenn ich eine Map[String,String]("url" -> "xxx", "title" -> "yyy"), ist es ein Weg, um generisch die Umwandlung in eine case class Image(url:String, title:String)? Kann ich schreiben Sie einen Helfer: object Image{ def fromMap(params:Map[String,String]) = Image(url=params("url"), title=params("title")) }

case class map scala

Wie übergeben Sie optional parameter scala Vorlage in play framework 2

2 Antworten

Ist es möglich, die java-controller in playframework 2-pass optionalen parameter auf der scala-Seite? Ich habe ein scala-Seite, die ich bin rendering von verschiedenen Aktionen. nur in einem bestimmten Fall eine dieser Aktionen soll ein parameter übergeben werden,

playframework-2.0 scala

Scala: Durchlaufen einer Sequenz, während Sie es ändern?

4 Antworten

Ich versuche zu implementieren, die Sieb des Eratosthenes in Scala. Ich beginne, indem ich die Initialisierung einer Folge aller ungeraden zahlen plus 2: //(end goal is to find all prime factors of bigNumber) val largestPrime : Long

functional-programming iterator scala sieve-of-eratosthenes

Slick verwirrt über numThreads und best practice für eine gute Leistung

1 Antworten

Ich bin mit dem PlayFrameWork mit Slick und verwenden es in einem system, das alle I/O-Datenbank schwer. In meinem application.conf - Datei habe ich diese Einstellung: play { akka { akka.loggers = ["akka.event.slf4j.Slf4jLogger"] loglevel = WARNING actor

playframework scala slick

Scala-Namenskonvention für Züge

4 Antworten

Angenommen ich habe eine trait im Scala trait Connection { def init(name: String) def dispose } Und ich möchte erstellen Sie eine Klasse, die es implementiert. Aber ich möchte es nennen wie Connection auch: class Connection extends

scala

Spark scala : iterierbar zu einzelnen Schlüssel-Wert-Paare

1 Antworten

Ich habe ein problem mit Funken-Scala Umwandlung eines Iterierbar (CompactBuffer) zu einzelnen Paare. Ich will erstellen Sie eine neue RDD-mit Schlüssel-Wert-Paare, von denen in der CompactBuffer. Sieht es wie folgt aus: CompactBuffer(Person2, Person5) CompactBuffer(Person2, Person5, Person7) CompactBuffer(Person1,

apache-spark iterable key-value scala

Mehrfache Zuordnung von non-Tupel in scala

3 Antworten

Nur zu klären, wenn ich sage, mehrere assigment, parallele-Zuweisung, destructuring bind ich meine das folgende pattern-matching gem scala> val (x,y) = Tuple2("one",1) x: java.lang.String = one y: Int = 1 was weist "one" zu x und 1

arrays functional-programming pattern-matching scala variable-assignment

initialisieren eine Variable in scala

3 Antworten

Habe ich eine Klasse, wo ich gerne meine initialisieren var, indem man eine Configdatei, produziert, die dazwischenliegende Objekte/vals, würde ich gerne Gruppe und verstecken sich in einer Methode. Hier ist das minimum, das problem - ich nenne

scala

Un-optioning eine optioniert Option

6 Antworten

Sagen, dass ich eine val s: Option[Option[String]]. Es können somit die folgenden Werte haben: Some(Some("foo")) Some(None) None Will ich reduzieren, so dass das erste wird Some("foo") während die beiden anderen werden None. Offensichtlich gibt es viele Wege,

flatten join monads option scala

Nicht unterstützte literal-Typ-Klasse in Apache Spark in scala

1 Antworten

Habe ich folgende Daten: +---------------+-----------+-------------+-----+------+ | time_stamp_0|sender_ip_1|receiver_ip_2|count|attack| +---------------+-----------+-------------+-----+------+ |06:10:55.881073| 10.0.0.3| 10.0.0.1| 1 | 0| |06:10:55.881095| 10.0.0.3| 10.0.0.1| 2 | 0| |06:10:55.881114| 10.0.0.3| 10.0.0.1| 3 | 0| |06:10:55.881133| 10.0.0.3| 10.0.0.1| 4 | 0| |06:10:55.881152| 10.0.0.3| 10.0.0.1| 5 |

apache-spark scala

Funke : Wie mapPartition und erstellen/Verbindung schließen pro partition

2 Antworten

So, ich möchte, um bestimmte Operationen auf meine Funke DataFrame, schreibt Sie in die DB und erstellen Sie einen anderen DataFrame am Ende. Es sieht wie folgt aus : import sqlContext.implicits._ val newDF = myDF.mapPartitions( iterator =>

apache-spark rdd scala

Wie verwenden Sie Formlos in einer Quasiquote?

1 Antworten

Ich versuche zu nennen, einen Shapeless makro in eine quasiquote mit Scala und ich bin nicht immer was ich möchte. Mein makro nicht wieder irgendwelche Fehler, aber es nicht erweitern Witness(fieldName) in Witness.Lt[String] val implicits = schema.fields.map

scala scala-macros scala-quasiquotes shapeless

Wie konnte ich initialisieren val Objekt im try-catch-block?

2 Antworten

Ich habe diesen code in Scala a - Objekt sollte der Wert nicht in eine variable, Wie kann ich die initialisieren der a Objekt im try-block? object SomeObject { private val a : SomeClass try { a=someThing

scala

Wie Konfiguriere ich die GARN-Adresse für Garn-client-Modus in der Funke?

1 Antworten

Von einem remote-scala-Programm, mit Spark 1.3, wie Initialisiere ich die sparkContext so dass ich kann eine Verbindung zu Spark läuft am GARN? also wo setze ich die Adresse des GARN-Knoten(s)? Derzeit mein Programm enthält: val conf =

apache-spark scala

Scala-coding-Stilen und Konventionen?

6 Antworten

Denke ich, dass Scala geht zu weit von der Einfachheit, wie Ihre syntax. Zum Beispiel Martin Odersky, schrieb die Methode in seinem Buch : def calculate(s: String): Int = if (cache.contains(s)) cache(s) else { val acc =

scala

Wie teilt man einen string mit doppelten Anführungszeichen " als Trennzeichen?

6 Antworten

Versuchte ich-Spaltung wie diese- tableData.split("\\"") aber es funktioniert nicht. InformationsquelleAutor Goku__ | 2015-05-01

java scala

Welche Art zu verwenden, zu speichern, eine in-memory-veränderliche Daten-Tabelle in der Scala?

5 Antworten

Jedes mal, wenn eine Funktion aufgerufen wird, wenn es für einen gegebenen Satz von argument-Werten ist noch nicht memoized ich möchte das Ergebnis in einer Tabelle im Arbeitsspeicher. Eine Säule gemeint ist, die zum speichern eines Ergebnisses,

data-structures memoization scala scala-collections

Wie kann ich eine Aktion ausführen auf server startup in die Scala, Play Framework?

1 Antworten

Habe ich eine config-Datei servers.conf in meinem conf/ - Verzeichnis, das Lesen von meinem ServerController, wenn die route /servers ist der hit. Das ist nicht performant, weil es erfordert ein neu-Einlesen der Konfiguration-Datei auf jedem aufeinander folgenden

playframework playframework-2.5 scala startup

Slick und filtern Sie die Option Spalten

1 Antworten

Ich versuche, die filter gegen einen optionalen Datums-Spalte mit Scala Slick 1.0.1. Kann es sein das ich nur nicht sehe, aber ich habe eine Tabelle, die sieht ungefähr so aus: case class UserRole(id:UUID, userID:UUID, role:String) object UserRole

scala scalaquery slick

Scala einzige Methode, Schnittstelle Implementierung

3 Antworten

Tut Scala irgendwelche syntaktischen Zucker ersetzen Sie den folgenden code: val thread = new Thread(new Runnable { def run() { println("hello world") } }) mit etwas mehr wie: val thread = new Thread(() => println("hello world")) in

interface lambda scala syntactic-sugar traits

Scala - wie gehen beheben "Wert ist, der nicht Mitglied des Nichts" Fehler

1 Antworten

Dieser Beispiel-code ist auf die Atmosphäre Klassen, aber wenn jemand könnte mir einige Einblicke in das, was die Fehlermeldung bedeutet im Allgemeinen, ich denke, ich kann herausfinden, alle Atmosphäre-spezifische Lösung... val bc = BroadcasterFactory.getDefault().lookup(_broadcasterId) bc.broadcast(message) Nach der

atmosphere compilation scala

Das Lesen einer Avro Datei von scala

1 Antworten

Ich versuche zu Lesen ein avro-Datei mit scala. Ich habe die Datei extrahiert schema mit avro-tools und als Datei gespeichert, dann versuche ich, es zu Lesen mit dem folgenden code: val zibi= scala.io.Source.fromFile("/home/wasabi/schema").mkString val schema_obj = new

avro scala

Scala: Einfache webservice

2 Antworten

Ich würde gerne zum erstellen eines einfachen webservice in scala ähnlich: http://www.artima.com/lejava/articles/threeminutes.html Gibt es eine einfache Möglichkeit, dies zu tun? EDIT: ich fand ein tutorial für lift http://wiki.liftweb.net/index.php/HowTo_do_Web_Services. Allerdings scheint dies viel zu kompliziert für das, was

scala web-services

Wie funktioniert orElse arbeiten auf PartialFunctions

3 Antworten

Ich bin immer sehr bizarres Verhalten (zumindest so scheint es mir) mit der orElse Methode definiert PartialFunction Es scheint mir, dass: val a = PartialFunction[String, Unit] { case "hello" => println("Bye") } val b: PartialFunction[Any, Unit] =

functional-programming partialfunction read-eval-print-loop scala

Verständnis Scala: die übergabe von Funktionen als Argumente

3 Antworten

Bin ich angefangen zu lernen, Scala und ich bin gekommen, über einen Ausschnitt aus der Programmierung in Scala lehrbuch die ich nicht ganz nachvollziehen. Hatte gehofft, jemand könnte mir helfen? Dies ist aus Listing 9.1 von der

scala

Gleichzeitige anzeigen/foreach in scala

7 Antworten

Ich habe eine iteration vals: Iterable[T] und eine lang andauernde Funktion ohne relevante Nebenwirkungen: f: (T => Unit). Das ist im Augenblick angewendet, um vals in der offensichtlichen Weise: vals.foreach(f) Ich würde gerne die Aufrufe f zu

concurrency functional-programming scala

Scala-Klasse-Mitglieder und Konstruktor-Parameter name clash

4 Antworten

Betrachten Sie die folgende Klasse in Java geschrieben: class NonNegativeDouble { private final double value; public NonNegativeDouble(double value) { this.value = Math.abs(value); } public double getValue() { return value; } } Es wird ein final-Feld namens value

constructor field properties scala

So erstellen Sie ein Diagramm in graphx

1 Antworten

Ich bin neu in scala und graphx und habe Probleme beim konvertieren einer tsv-Datei zu einem Diagramm. Ich habe einen flachen tab-getrennte Datei wie unten: n1 P1 n2 n3 P1 n4 n2 P2 n3 n3 P2 n1

apache-spark graph scala scala-2.10 scala-collections

Wie kann ich überprüfen, invokations mit bestimmten string-Matcher in Specs2 mit Mockito

1 Antworten

Habe ich einen test in dieser Richtung: httpClient.post(anyString, anyString) returns (first, second) //do my thing there were two(httpClient).post(anyString, anyString) Dies funktioniert gut, aber ich wollen, stellen Sie sicher, dass der erste Aufruf übergibt einen anderen Körper als

mockito scala specs2

Entfernen Sie einen Schlüssel aus einer JsValue in Scala

2 Antworten

Es ist wahrscheinlich eine sehr einfache Frage, aber ich habe Schwierigkeiten eine saubere/funktionierende Lösung. Ich will einfach nur, um ein Feld zu entfernen, aus einem json-Objekt, das ich habe. Sagen wir, ich habe : val body:Option[JsValue] =

playframework-2.0 scala