kryo

0熱度

2回答

我有一個case class User。我必須使用kryo序列化它。這是我的班。雖然執行Kryo read（）我有問題。我的變量有val類型。因爲我們知道我們不能改變val的價值。 case class User(name : String, age : int) extends KryoSerializable { def this()={ this("",0)

5熱度

1回答

異常的寒冷，KRYO

我想從這個 link 運行弛斯卡拉示例代碼，我有兩個虛擬case類一個是用戶 @SerialVersionUID(1) case class User(name :String, age : Int) extends Serializable 和其他是學生 @SerialVersionUID(2) case class Student(sub : String , id : Int ,

-1熱度

1回答

java kryonet - ChatMessage - 類未註冊

我剛開始使用kryonet。從示例文件夾運行時，聊天示例正常工作。如果我將聊天客戶端，服務器和網絡文件複製到eclipse中的另一個源文件夾中，我得到IllegalArgumentException：類未註冊：com.esotericsoftware.kryonet.examples.chat.Network $ RegisterName（請參見下文）。我在「kryo.register（C

7熱度

1回答

使用一個集合$ UnmodifiableCollection與Apache弗林克

雖然使用Apache弗林克用下面的代碼： DataStream<List<String>> result = source.window(Time.of(1, TimeUnit.SECONDS)).mapWindow(new WindowMapFunction<String, List<String>>() { @Override public void mapWindow(

1熱度

1回答

KRYO字節級追加

我存儲JSON在一個表（一個真正的卡桑德拉列族）是這樣的： ____________________________________________________________________ | || prop1 | prop2 | ... | | collection_id || [val1, val2, ...] | [val1, val2, ...] | ...

2熱度

1回答

Kryo序列化/反序列化

我試圖用kryo序列化和反序列化爲二進制。我想我有序列化工作，但我似乎無法反序列化。下面是我搞亂的代碼，但最終我想存儲一個字節[]，然後再讀一遍。該文檔僅顯示如何使用文件進行操作。 Kryo kryo = new Kryo(); kryo.register(ArrayList.class); kryo.register(Modifier.class); By

3熱度

2回答

如何在flink中使用joda.time（或者如何使用typeutils.runtime.kryo）

在flink項目中，我使用了一個case class click。 case class click(date: LocalDateTime, stbId:String, channelId :Int) 此類填充數據集，它能正常工作的日期作爲一個Java 8 java.time.LocalDateTime。在java 7環境中切換到org.joda（version2.9）後，調用DataSet

1熱度

2回答

Apache Storm中的自定義序列化

我嘗試爲我在Apache Storm Spouts/Bolts中使用的Objects添加自定義序列化程序。現在我的代碼看起來像這樣： conf.registerSerialization(MyService.class, MyKryoSerializer.class); public class MyKryoSerializer extends Serializer<MyService> {

0熱度

1回答

使用KRYO非序列化到序列化類屬性

我使用KRYO串行序列化我的Java對象我的Java對象是這樣的 Class A { private Class B; private Class C; private Class D; int x ; int y; } B，C和d是第三方庫，而不是可串行化。另外我不能編輯他們的代碼。我使用這樣的Kryo來序列化 A a = new A（）; //填充A 的屬性Kryo kr

1熱度

1回答

阿卡 - KRYO-系列化的ClassNotFoundException：scala.Enumeration $瓦爾

有時更新版本的依賴我的項目的時候，當我會跑的項目，我會收到以下錯誤： ERROR 09:31:34:241 apply$mcV$sp - Class could not be loaded and/or registered: scala.Enumeration$Val ERROR 09:31:34:247 apply$mcV$sp - exception caught during akka-