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

Wie verwende ich spielen ws Bibliothek in normalen sbt-Projekt statt spielen?

Anzahl der Antworten 2 Antworten
, Wenn ich habe versucht, mit Spielen WS-Bibliothek in einem normalen sbt-Projekt statt-play-Projekt, an dem ich gebunden war, zu spielen.api.Spielen.aktuelle und bekam java.lang.RuntimeException: "Es wird keine Anwendung gestartet" wenn er versucht wird, um die Anwendung auszuführen. InformationsquelleAutor

Computing Rang einer Zeile

Anzahl der Antworten 1 Antworten
Ich möchte Ranges Benutzer-id basiert auf einem Feld. Für den gleichen Wert des Feldes, Rang sollte gleich sein. Dass Daten in Hive-Tabelle. z.B. user value a 5 b 10 c 5 d 6 Rank a - 1

Iterieren scala wrappedArray? (Funke)

Anzahl der Antworten 1 Antworten
Ich die folgenden Operationen durchführen: val tempDict = sqlContext.sql("select words.pName_token,collect_set(words.pID) as docids from words group by words.pName_token").toDF() val wordDocs = tempDict.filter(newDict("pName_token")===word) val listDocs = wordDocs.map(t => t(1)).collect() listDocs: Array [Any] = Array(WrappedArray(123, 234, 205876618, 456)) Meine Frage

Schreiben von Daten generiert, die in scala, um eine text-Datei

Anzahl der Antworten 1 Antworten
Ich hatte gehofft, jemand könnte helfen, ich bin neu in der scala und ich habe einige Fragen, schreiben Sie die Ausgabe in eine text-Datei. Ich habe eine Tabelle mit Daten und ich schrieb einige code zu Lesen

Wie konvertiere ich eine Java-byte-array in eine Scala byte-array?

Anzahl der Antworten 2 Antworten
Ich bin neu in Scala und arbeiten derzeit an einem Projekt, die Einbeziehung der Java-und Scala-Module. Jetzt würde ich mag, um den Anruf eine Scala-Methode aus Java mit einem parameter vom Typ byte. Den Scala-Methode hat die

scala-Wert toInt ist kein Mitglied einer

Anzahl der Antworten 3 Antworten
Das println in der folgende code funktioniert (mit oder ohne toInt) println("retweets : ", e.getOrElse("retweets", 0).toInt) top10Tweets(""+e.get("text").get, e.getOrElse("retweets", 0).toInt) Aber wenn ich übergeben Sie als argument einer Funktion (wie oben), funktioniert es nicht. Es sagt, "value toInt

Die Durchsetzung der Java-version für Scala-Projekt in der sbt?

Anzahl der Antworten 6 Antworten
Meine scala-Anwendung läuft nur mit Java 7, da kommt es auf Bibliotheken, die nur erschien in dieser version des JDK. Wie kann ich erzwingen, dass in sbt, so dass die korrekte Fehlermeldung wird sofort angezeigt, wenn der

Kann scala.util.Random.nextInt (): Int gelegentlich eine negative Rendite Wert?

Anzahl der Antworten 4 Antworten
Dokumentation für scala.util.Random.nextInt (n: Int): Int sagt "Gibt einen Pseudo-zufälligen, gleichmäßig verteilten int-Wert zwischen 0 (einschließlich) und dem angegebenen Wert (exklusive)...", während er für scala.util.Random.nextInt (): Int es sagt "liefert die nächste Pseudo-zufälligen, gleichmäßig verteilten int-Wert...", ohne

Wie Sie warten für N Sekunden zwischen den Aussagen in Scala?

Anzahl der Antworten 2 Antworten
Habe ich zwei Aussagen wie diese: val a = 1 val b = 2 Zwischen den 2 Aussagen, ich will die pause für N Sekunden wie kann ich in bash mit sleep Befehl. InformationsquelleAutor Mamun | 2016-02-20

Wie kann ich merge spark-Ergebnis-Dateien ohne neu partitionieren und copyMerge?

Anzahl der Antworten 3 Antworten
Verwende ich folgenden code: csv.saveAsTextFile(pathToResults, classOf[GzipCodec]) pathToResults Verzeichnis viele Dateien hat, wie Teil-0000, Teil-0001 usw. Die ich verwenden kann, FileUtil.copyMerge(), aber es ist wirklich langsam ist, ist es alle Dateien herunterladen, auf Fahrer-Programm und dann laden Sie

Gibt es eine API-Methode vergleicht den Inhalt von Seq unabhängig von der Reihenfolge?

Anzahl der Antworten 2 Antworten
Vorausgesetzt: val l1 = List(1,2,3) val l2 = List(2,3,1) Will ich eine Methode, die bestätigt, dass l1 gleich l2 (wie in gleichen Inhalt, aber unterschiedlicher Reihenfolge). Gibt es eine API-Methode, die auf List/Seq, dies zu tun? l1.sameElements(l2)

Ist es zulässig, zu reduzieren auf einen leeren Menge von Mengen?

Anzahl der Antworten 3 Antworten
Sollte dies nicht funktionieren? > val setOfSets = Set[Set[String]]() setOfSets: scala.collection.immutable.Set[Set[String]] = Set() > setOfSets reduce (_ union _) java.lang.UnsupportedOperationException: empty.reduceLeft at scala.collection.TraversableOnce$class.reduceLeft(TraversableOnce.scala:152) [...] reduzieren ist ein Spezialfall der Faltung. Sie wollen wahrscheinlich foldLeft ausgehend von der

Scala Aktualisierung der Array-Elemente

Anzahl der Antworten 1 Antworten
Ich hätte nie gedacht, ich wäre zu Fragen, wie eine einfache Frage, aber wie aktualisiere ich auf die array-Elemente in scala Ich habe erklärt die innere Funktion in meiner Main-Objekt, und ich habe so etwas wie dieses

Wie Sie ein upgrade Scala auf eine neuere version von der Kommandozeile aus?

Anzahl der Antworten 3 Antworten
Ist es Weg, um das upgrade installierten Scala-version via sbt /anderen Kommandozeilen-tool? Ich bin mir sicher, dass es einen Weg gibt, aber ich konnte nicht finden, dass jeder nach einer kurzen Suche, bin ich etwas fehlt? Dies

Scala Referenz-Gleichheit

Anzahl der Antworten 1 Antworten
Wie testen Sie Referenz-Gleichheit in Scala? val x = new Obj val y = x x.referenceEquals(y) //evaluates to true InformationsquelleAutor Landon Kuhn | 2011-07-26

Spray-json Deserialisieren verschachtelte Objekt

Anzahl der Antworten 2 Antworten
Wie Deserialisieren verschachtelte Objekte korrekt in spray-json? import spray.json._ case class Person(name: String) case class Color(n: String, r: Int, g: Int, b: Int, p: Person) object MyJsonProtocol extends DefaultJsonProtocol { implicit object ColorJsonFormat extends RootJsonFormat[Color] { def

In Scala, warum NaN nicht abgeholt wird durch pattern-matching?

Anzahl der Antworten 3 Antworten
Meine Methode ist wie folgt def myMethod(myDouble: Double): Double = myDouble match { case Double.NaN => ... case _ => ... } Den IntelliJ-debugger zeigt NaN aber das ist nicht abgeholt wird, die in mein Suchmuster. Gibt

Scala Konstruktor Parameter

Anzahl der Antworten 2 Antworten
Was ist der Unterschied zwischen einem privaten Konstruktor var-parameter und einen Konstruktor ohne parameter val/var? Sind Sie gleichen in Bezug auf scope/Sichtbarkeit? Ex: class Person(private var firstName:String, lastName:String) Überprüfen Sie heraus diese Frage: stackoverflow.com/questions/15639078/... Dies hat eine

Ausschließen Gurken tags

Anzahl der Antworten 2 Antworten
Habe ich einen Haufen davon Fälle mit verschiedenen Gurken-tags. In meinem Haupt-runner-Klasse ausschließen will ich alle Szenarien, die entweder in one @oder @die zwei. Also, unten sind die Optionen, die ich habe versucht, Option 1 @CucumberOptions(tags=Array("[email protected],[email protected]"), .....)

Wie zum Hohn eine Scala singleton-Objekt?

Anzahl der Antworten 4 Antworten
Ich versuche, mich zu verspotten, ein Scala singleton-Objekt. Insbesondere brauche ich zum simulieren der Objekt play.api.libs.ws.WS im service-Komponente (class under test). Mit Mockito ist dies nicht möglich, die test-Durchführung scheitert in der folgenden Weise: [error] MockitoException: :

Verwendung von SQL "LIKE" - operator in GLATTEN

Anzahl der Antworten 1 Antworten
Vielleicht eine dumme Frage. Aber ich habe keine Antwort gefunden bisher. So, wie Sie repräsentieren das SQL "LIKE" - operator in SLICK? InformationsquelleAutor wassertim | 2013-02-05

java.io.IOException: Nein Dateisystem für die Regelung : hdfs

Anzahl der Antworten 3 Antworten
Ich bin mit Cloudera Quickstart VM CDH5.3.0 (in Bezug auf Pakete bündeln) und Funke 1.2.0 mit $SPARK_HOME=/opt/cloudera/parcels/CDH-5.3.0-1.cdh5.3.0.p0.30/lib/spark und Absenden Spark-Anwendung mit dem Befehl ./bin/spark-submit --class <Spark_App_Main_Class_Name> --master spark://localhost.localdomain:7077 --deploy-mode client --executor-memory 4G ../apps/<Spark_App_Target_Jar_Name>.jar Spark_App_Main_Class_Name.scala import org.apache.spark.SparkContext import

Simulieren von Eingaben von der Standardeingabe, wenn ein scala-Programm in intellij

Anzahl der Antworten 2 Antworten
Gibt es eine Möglichkeit, konfigurieren Sie die Befehl Linie Argumente, um intellij für stdin-Umleitung? Etwas entlang der Linien von: Ausführen | Bearbeiten Von Run Configurations | Script Parameter /shared/java/paf-rules.properties 2 < /shared/java/testdata.csv Diese sollten zusammengeführt werden, mit

Was ist erforderlich, um sbt build mit Akka?

Anzahl der Antworten 3 Antworten
Ich bin versucht, die scala akka von sbt. Meine sbt-Datei sieht wie folgt aus: name := "hello" version := "1.0" scalaVersion := "2.9.1" resolvers += "akka" at "http://repo.akka.io/snapshots" libraryDependencies ++= Seq( "com.codahale" % "simplespec_2.9.0-1" % "0.4.1", "com.typesafe.akka"

Gatling - Log-body der Anfrage in die simulation.log oder in der Konsole

Anzahl der Antworten 3 Antworten
Ich würde gerne sehen, was ist in den Körper der post, die ich sende in meinem Skript. In der Tat, würde ich mag, um zu sehen, fordern, verlangen Körper und Antwort. Aus der Suche in der Dokumentation

Funke: Erhöhung der Anzahl von Partitionen, ohne dass ein shuffle?

Anzahl der Antworten 3 Antworten
Wenn die Verringerung der Anzahl von Partitionen kann man verwenden coalesce, das ist toll, weil es nicht zu einem shuffle-und scheint zu funktionieren sofort (keine zusätzliche job-Phase). Möchte ich das Gegenteil tun manchmal, aber repartition induziert einen

JavaFX vollständig angepasste windows?

Anzahl der Antworten 2 Antworten
Ich würde gerne ein Programm haben, wo ich ganz individuell auf dem Fenster das Erscheinungsbild. Bisher habe ich gelernt, dass ich entfernen können Sie die typischen Fenster, die Dinge mit: class Application extends javafx.application.Application { /** *

Wie zu analysieren und extrahieren von Informationen aus dem json-array mit json4s

Anzahl der Antworten 1 Antworten
Ich bin versucht derzeit, das extrahieren der Informationen aus einem json-array mit json4s (scala). Beispiel-Daten wie folgt: val json = """ [ {"name": "Foo", "emails": ["[email protected]", "[email protected]"]}, {"name": "Bar", "emails": ["[email protected]", "[email protected]"]} ] """ Und mein code

konnte nicht finden, impliziten Wert für Beweise parameter vom Typ org.apache.flink.api.common.typeinfo.TypeInformation[...]

Anzahl der Antworten 3 Antworten
Ich bin versucht, zu schreiben einige Anwendungsfälle für Apache Flink. Ein Fehler, ich Laufe ziemlich oft ist could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[SomeType] Mein problem ist, dass ich kann nicht wirklich festzunageln,

scala - yield-syntax

Anzahl der Antworten 1 Antworten
Ich bin, ein Buch zu Lesen auf der scala-Programmierung (die Programmierung in Scala), und ich habe eine Frage über die Ausbeute syntax. Laut dem Buch, die syntax für den Ertrag ausgedrückt werden kann wie: für Klauseln Rendite

Wie zu verwenden ListBuffer in scala?

Anzahl der Antworten 5 Antworten
Habe ich eine situation, wo ich bin vorbei ein einzelnes element der Liste um eine Methode. Innerhalb dieser Methode, das einzelne element in der Liste um eins erhöht. So, dass nach Aufruf der Methode wird die Liste

Wiederholen eine Liste, in der Scala

Anzahl der Antworten 4 Antworten
Ich bin ein Scala noob. Ich haben beschlossen, schreiben ein spider solitaire solver als erste übung die Sprache zu lernen und die funktionale Programmierung im Allgemeinen. Möchte ich generieren, die einem zufällig gemischten Kartenstapel mit 1, 2

Warum ist die `unary_ " - Präfix benötigt in scala?

Anzahl der Antworten 2 Antworten
Anfänger Scala Frage, aber ich konnte nicht finden die Antwort hier. Ähnlich überladen in C++, ich würde erwarten, dass der compiler kann sagen, der Unterschied zwischen einer Methode namens - nimmt einen parameter (mit dem gleichen Typ

Akka Schauspieler - warten Sie einige Zeit, um zu erwarten, dass eine Nachricht, ansonsten eine Nachricht senden

Anzahl der Antworten 3 Antworten
Ist es möglich, einen Actor warten für X Anzahl der Sekunden zu erhalten, jede Nachricht, und wenn eine Nachricht empfangen wird, verarbeiten Sie es wie gewohnt, ansonsten senden eine Nachricht zu einige andere Actor (pre-bestimmt im Konstruktor)?

Was ist die version der library Funke unterstützt SparkSession

Anzahl der Antworten 2 Antworten
Code Spark mit SparkSession. import org.apache.spark.SparkConf import org.apache.spark.SparkContext val conf = SparkSession.builder .master("local") .appName("testing") .enableHiveSupport() //<- enable Hive support. .getOrCreate() Code pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.cms.spark</groupId> <artifactId>cms-spark</artifactId> <version>0.0.1-SNAPSHOT</version> <name>cms-spark</name> <pluginRepositories> <pluginRepository> <id>scala-tools.org</id> <name>Scala-tools Maven2

IOException: Cannot run program "javac": CreateProcess error=2, Das system kann nicht die angegebene Datei gefunden

Anzahl der Antworten 2 Antworten
Bekam ich die Fehlermeldung "IOException: Cannot run program "javac": CreateProcess error=2, Das system kann nicht die angegebene Datei gefunden werden" beim laufen meinen scala-Projekt in 2 spielen. warum dieser Fehler auftreten . Bitte dieses problem lösen. Sehen:

Pattern matching auf eine Liste, in der Scala

Anzahl der Antworten 3 Antworten
Ich bin ein wenig verwirrt über pattern-matching auf eine Liste, in der Scala. Zum Beispiel. val simplelist: List[Char] = List('a', 'b', 'c', 'd') //> simplelist : List[Char] = List(a, b, c, d) def simple_fun(list: List[Char]) = list

Übergeordnete mehrere config-Werte in Typesafe config bei Verwendung eines uberjar bereitstellen

Anzahl der Antworten 3 Antworten
Habe ich schon eine Akka Anwendung, die mehrere Konfigurations-Werte (IP-Adresse, port-Nummern) definiert in resource/application.conf. Ich bin mit der sbt-assembly plugin, um eine uber jar, und dann die Bereitstellung dieses jar. Gibt es eine Möglichkeit, das überschreiben der

Spark - Random Number Generation

Anzahl der Antworten 4 Antworten
Ich habe geschrieben eine Methode, die berücksichtigen muss, eine Zufallszahl zu simulieren, die eine Bernoulli-Verteilung. Ich bin mit random.nextDouble generiert eine Zahl zwischen 0 und 1 ist, dann macht meine Entscheidung basierend auf diesem Wert, da meine

For-Schleife in scala ohne Reihenfolge?

Anzahl der Antworten 4 Antworten
So, während der Arbeit meinen Weg durch die "Scala" für die Ungeduldigen" ich Frage mich: Können Sie ein Scala for-Schleife, ohne eine Sequenz? Gibt es zum Beispiel eine übung in dem Buch, das Sie fragt, zu bauen,

instanziieren Objekt mit der Reflexion über Konstruktor-Argumente

Anzahl der Antworten 3 Antworten
Ich versuche, herauszufinden, wie zu instanziieren Fall Klasse-Objekt mit reflektion. Gibt es Unterstützung für diese? Der nächste, den ich gekommen bin, sucht in der scala.reflektieren.Aufruf, aber dies scheint mehr für das ausführen von Methoden, die einen Teil

Konvertieren Scala Option, um Java Optional

Anzahl der Antworten 7 Antworten
Muss ich konvertieren Scala Option, um Java Optional. Ich schaffte es schrieb: public <T> Optional<T> convertOption2Optional(Option<T> option) { return option.isDefined() ? Optional.of(option.get()) : Optional.empty(); } Aber ich mag es nicht. Gibt es eine einfache Möglichkeit, es zu

Scala 2.10 Reflexion, wie extrahiere ich das Feld Werte aus einer Fall Klasse, d.h. Feldliste von Fall Klasse

Anzahl der Antworten 2 Antworten
Wie kann ich extrahieren Sie die Werte von Feldern aus einer Fall-Klasse in scala mit der neuen reflection-Modell in scala 2.10? Zum Beispiel, indem die unten nicht, ziehen Sie die Feld-Methoden def getMethods[T:TypeTag](t:T) = typeOf[T].members.collect { case

Spark Zeile JSON

Anzahl der Antworten 4 Antworten
Ich möchte eine JSON von einer Spark-v. 1.6 (mit scala) dataframe. Ich weiß, dass es die einfache Lösung zu tun df.toJSON. Allerdings ist mein problem etwas anders aussieht. Betrachten Sie zum Beispiel einen dataframe mit den folgenden

Spark mehreren Kontexten

Anzahl der Antworten 4 Antworten
In kurzen : EC2-cluster: 1 master-3 slaves Spark version : 1.3.1 Ich wollen, verwenden Sie die option Funken.- Treiber.allowMultipleContexts, einem lokalen Kontext (nur master) und ein cluster (master und slaves). Bekomme ich diese stacktrace des Fehlers (Zeile

Was ist Scala ' s Simple Build Tool (sbt) und warum wird es verwendet?

Anzahl der Antworten 1 Antworten
Ich bin neu im Scala und ich habe zu lernen, Scala und SBT, ich lese das sbt-tutorial, aber ich bin nicht in der Lage zu verstehen, die Verwendung von sbt, für welchen Zweck Sie gebraucht wurde.Nach der

Ist gzip-format unterstützt in der Funke?

Anzahl der Antworten 1 Antworten
Für eine Big-Data-Projekt, ich bin der Planung bis zur Nutzung spark, die hat einige nette features, wie in-memory-Berechnungen für die wiederholte workloads. Es kann auf lokale Dateien oder auf dem HDFS. Jedoch in der offiziellen Dokumentation kann

Wie zufällig Stichprobe aus einer Scala-Liste oder ein array?

Anzahl der Antworten 7 Antworten
Möchte ich zufällig Probe aus einer Scala-Liste oder ein array (keine RDD), die Größe der Stichprobe kann wesentlich länger sein als die Länge der Liste oder ein array, wie kann ich dies tun effizient? Da die Größe

Ist es möglich mit gradle zu entwickeln scala-Projekte?

Anzahl der Antworten 2 Antworten
Ich bin mit sbt zu bauen scala-Projekte, aber es scheint immer zu Komplex(unbekannt) und schwer für mich. Ich bin auch mit gradle bauen, java-Projekte, und das macht mich glücklich. Frage ich mich, ist es möglich, mit gradle

Idee sbt java.lang.NoClassDefFoundError: org/apache/spark/SparkConf

Anzahl der Antworten 3 Antworten
Ich bin ein Anfänger der Funke.Ich Baue eine Umgebung, die Nutzung von linux + Idee + sbt" ,wenn ich versuche, das schnelle starten von Spark,ich bekomme das problem: Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/spark/SparkConf at test$.main(test.scala:11) at