kryo

1熱度

1回答

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

0熱度

1回答

爲什麼使用Kryo序列化框架進入apache風暴時將在數據獲取值時寫入數據

也許大多數開發人員是使用AVRO作爲Kafka和Apache Storm方案中的序列化框架。但是我需要處理大多數複雜的數據，然後我發現Kryo序列化框架也成功地將它集成到了我們的項目中，該項目遵循Kafka和Apache Storm環境。但是，當想要進一步操作時，就有一種奇怪的狀態。我已經發送了5封郵件給卡夫卡，風暴工作也可以讀取5條消息並反序列化成功。但接下來的印跡得到的數據值是錯誤的。在那裏

-1熱度

1回答

如何清楚地確定文件是否不是我想要的類型？

我正在使用Kryo來保存用戶數據的二進制文件。用戶可以在我的應用程序中打開其中的一個文件。我不確定我是否有乾淨的方法來檢測他們是否嘗試打開其他類型的文件。現在，我正在寫一個簡單的FileHeader對象到用戶數據之前的文件。文件標題包含有關應用程序的哪個版本保存了該文件的信息。 public void write (UserProject project, File file) throws F

6熱度

2回答

當您使用Pyspark時，您是否受益於Kryo序列化程序？

我讀到Kryo序列化器可以在Apache Spark中使用時提供更快的序列化。不過，我通過Python使用Spark。我是否仍然從切換到Kryo序列化器中獲得顯着的好處？

0熱度

1回答

Kryo序列化empy反序列化

我重構我的代碼以使用kryo序列化。一切工作正常，除了從某些類反序列化geomtry的屬性。不會引發異常（我將「spark.kryo.registrationRequired」設置爲true）。在調試時，我嘗試收集數據，我發現geomtry中的數據只是空的。結果我明白反序列化失敗了。幾何是從任何類型的任何（斯卡拉），因爲它可能是一個複雜的屬性。我的問題是爲什麼數據是空的，是否有連接到屬性

2熱度

1回答

使用Kryo將HashMap序列化到Redis

我試圖根據Kryo serlization如何工作。我有一個非常大的HashMap，我想推入Redis。 HashMap是： HashMap<String, HashMap<String, Set<Long>>> cache = new HashMap<>(); 什麼是序列化成Redis的最快方法？選項1：直接進入Redis？我看到，你可以使用Kryo像： Kryo kryo = new

1熱度

1回答

Android SnappyDB危險權限

我正在更新應用程序到android targetSdk = 23，現在正在處理權限請求。我需要得到一些dangerous permission爲snappyDB library（它使用kryo library裏面）嗎？我的意思是這個權限： READ_EXTERNAL_STORAGE WRITE_EXTERNAL_STORAGE 謝謝！

0熱度

1回答

java kryo 3.0.3低對象的序列化速度

我試圖通過使用kryo庫來獲得更好的對象序列化性能。我隔壁班的 public class CustomClass { private String name; private int[] array; public CustomClass(String name, int size){ this.name = name; fillArr

0熱度

1回答

通過Kryonet發送對象導致崩潰

我想使用Kryonet發送對象。對於大多數對象來說它工作正常，但對於我自己的Vector實現來說，它會崩潰。課程在雙方註冊。它包含一個空構造函數，並且所有變量都被公開化。 public strictfp class StrictVector2f implements StrictVector { public double x; public double y;

0熱度

2回答

使用Kryo序列化quickfix.Message

我試圖使用kryo序列化序列化一個quickfix.Message實例。我正在使用kryo 3.0.3版本。的代碼片段如下： Message fixMessage = getFixMessage(); Kryo kryo = new Kryo(); kryo.register(Message.class); ByteArrayOutputStream outp