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回答

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

    1熱度

    1回答

    我們使用Kryonet通過RMI調用服務器方法。 如果服務返回正常值(如true/false),它工作正常。 但是,當服務拋出異常,我們得到一個無限循環導致服務器上的StackOverflowError。 Exception in thread "Server" java.lang.StackOverflowError at com.esotericsoftware.kryo.Kryo.getR

    -1熱度

    1回答

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

    7熱度

    1回答

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

    1熱度

    1回答

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

    2熱度

    1回答

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

    3熱度

    2回答

    在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 Spouts/Bolts中使用的Objects添加自定義序列化程序。現在我的代碼看起來像這樣: conf.registerSerialization(MyService.class, MyKryoSerializer.class); public class MyKryoSerializer extends Serializer<MyService> {

    0熱度

    1回答

    我使用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