kryo

8Hitze

1Antwort

Spark Kryo: Registrieren Sie einen benutzerdefinierten Serializer

Ich habe eine Klasse, die einen benutzerdefinierten Kryo-Serialisierer implementiert, indem Sie die read() und write() Methoden von com.esotericsoftware.kryo.Serializer (siehe Beispiel unten) implemen

scala apache-spark kryo 2016-03-22

---

0Hitze

1Antwort

KryoNet - Senden von Paketen an Android-Clients

Ich entwickle eine Android App, die Clients an meinen Server zum Senden/Empfangen unterschiedlicher Art von Paketen verbinden muss. Um das zu erreichen, verwende ich die KryoNet Bibliothek. Meine Clie

java android networking kryo kryonet 2016-03-22

---

7Hitze

1Antwort

Mit einem Kollektionen $ UnmodifiableCollection mit Apache Flink

Während Apache Flink mit dem folgenden Code: DataStream<List<String>> result = source.window(Time.of(1, TimeUnit.SECONDS)).mapWindow(new WindowMapFunction<String, List<String>>() { @Override

kryo apache-flink 2015-09-08

---

2Hitze

1Antwort

Hazelcast 3.6.1 "Es gibt keinen geeigneten Deserializer für den Typ" Ausnahme

Ich benutze Hazelcast 3.6.1, um von einer Map zu lesen. Die in der Map gespeicherte Objektklasse heißt Schedule. Ich habe einen benutzerdefinierten Serializer auf der Clientseite wie folgt konfigurier

serialization client hazelcast kryo 2016-04-01

---

2Hitze

1Antwort

Serialize HashMap in Redis mit Kryo

Ich versuche zu unter wie Kryo Serlisierung funktioniert. Ich habe eine sehr große HashMap, die ich in Redis schieben möchte. Die HashMap ist: HashMap<String, HashMap<String, Set<Long>>> cache = new H

java redis kryo 2016-04-12

---

1Hitze

2Antwort

Kryo: IdentityObjectIntMap.clear() produziert enorme CPU-Last

Ich muss viele Objekte in meiner Anwendung mit Kryo serialisieren. Einige von ihnen sind wirklich große Objektgraphen, andere sind nur kleine Container mit ein paar Primitiven (aber es gibt eine Los d

java performance serialization concurrency kryo 2016-04-13

---

6Hitze

4Antwort

Wie Kryo Serializer Puffer in Spark zuweist

Bitte helfen zu verstehen, wie Kryo Serializer Speicher für seinen Puffer reserviert. Meine Spark-App schlägt bei einem Collect-Schritt fehl, wenn sie versucht, von Mitarbeitern 122 MB Daten an einen

apache-spark pyspark kryo 2015-08-11

---

5Hitze

2Antwort

Kryo Serializer verursacht Ausnahme auf zugrunde liegenden Scala-Klasse WrappedArray

Zwei Fragen, die Antwort auf die allgemeine wird mich darauf hinweisen, wie minimal ich eine MVCE machen kann. 1) Wie kann ich wissen, WrappedArray registrieren vorne, (und jede andere Klasse in Scala

java scala serialization apache-spark kryo 2016-01-12

---

5Hitze

1Antwort

Ausnahme in Chill Kryo

Ich versuche, den Beispielcode für Chill Scala von diesem link Ich habe zwei Dummy-Fallklassen ein laufen ist Benutzer @SerialVersionUID(1) case class User(name :String, age : Int) extends Serializab

scala serialization kryo 2015-08-31

---

8Hitze

1Antwort

anpassen SparkContext mit sparkConf.set (..) bei der Verwendung von Funken Shell

In Spark, gibt es drei grundlegende Möglichkeiten, die Optionen für die SparkConf verwendet zur Angabe der SparkContext zu erstellen: Als Objekte im conf /spark-defaults.conf zB die Zeile: spark.drive

scala apache-spark serialization kryo 2015-07-14

---