kryo

0热度

2回答

我试图使用kryo序列化序列化一个quickfix.Message实例。我正在使用kryo 3.0.3版本。的代码片段如下： Message fixMessage = getFixMessage(); Kryo kryo = new Kryo(); kryo.register(Message.class); ByteArrayOutputStream outp

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序列化器中获得显着的好处？

1热度

2回答

来自kafka的java bean的Storm Kafkaspout KryoSerialization问题主题

嗨，我是Storm和Kafka的新手。我使用风暴1.0.1和kafka 0.10.0 我们有一个kafkaspout可以从kafka主题接收java bean。我已经花了几个小时挖掘找到正确的方法。发现了很多有用的文章，但到目前为止，还没有任何方法对我有用。以下是我的代码： StormTopology： public class StormTopology { public stati

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;