Apache Storm中的自定义序列化
我尝试为我的对象添加自定义序列化程序，该程序在Apache Storm Spouts/Bolts中使用。现在我的代码是这样的：
conf.registerSerialization(MyService.class, MyKryoSerializer.class);
public class MyKryoSerializer extends Serializer<MyService> {
public MyKryoSerializer() {
System.out.println("New MyKryoSerializaer!");
}
@Override
public void write(Kryo kryo, Output output, MyService service) {
System.out.println(72);
}
@Override
public MyService read(Kryo kryo, Input input, Class<MyService> aClass) {
System.out.println(73);
return null;
}
public MyService copy(Kryo kryo, MyService myService) {
System.out.println("MyService!");
return myService;
}
}
public class MyRandomSpout extends BaseRichSpout {
private MyService service;
private SpoutOutputCollector collector;
...
所以，当我尝试在本地集群上启动Storm拓扑时，我会看到“New MyKryoSerializaer！”
在stdout中，因此调用构造函数，但不调用写/读方法。谁能告诉我，我做错了什么？Storm是否支持Skyo序列化程序进行斑点/螺栓序列化？
共有2个答案
为了让Storm使用我自己的序列化逻辑，我不得不在拓扑中添加以下配置：
config.put(Config.TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION, true);
其中config是我最终传递给submit方法的配置。
它看起来不像Storm支持Kryo系列化的螺栓或喷嘴。请参阅这一行，其中它显式地尝试使用Java序列化进行序列化。
-
easyopen序列化使用fastjson处理json，xstream处理xml。现在我们来自定义实现一个json处理： 新建一个类JsonFormatter，实现ResultSerializer接口 public class JsonFormatter implements ResultSerializer { @Override public String serialize(
-
我试图创建会影响序列化值的自定义jackson注释。 意思是： 现在序列化对象X（10）将导致： 我怎样才能做到这一点？
-
我有以下ORM对象（简化）： 每行有： 主键 插入行时的时间戳 computed_values要存储的实际JSONB数据 JSONB来存储计算数据的日期列表。 虽然我对列没有问题，但是对象不能被SQLAlchemy JSON序列化程序序列化。 我的想法是为该列重新定义对象的序列化程序行为。要做到这一点，我必须定义自己的自定义JSON序列化程序，或者使用一些现成的序列化程序，比如orjson。因为我
-
问题内容： 我有一个对象，其中包含一些要序列化的不可序列化字段。它们来自我无法更改的单独API，因此使它们可序列化不是一种选择。主要问题是Location类。它包含我需要的四个可以序列化的东西，所有整数。如何使用read / writeObject创建可以执行以下操作的自定义序列化方法： 我怎样才能做到这一点？ 问题答案： Java支持自定义序列化。阅读“自定义默认协议”部分。 去引用： 但是，有
-
问题内容： 我的代码结构如下。 和 基本上我正在扫描网站以获取统计信息，例如标题标签，重复标题等。 我正在使用JQuery并向Web服务进行AJAX调用并检索url统计信息，而该过程正在运行以显示到目前为止收集的用户url统计信息，因为扫描大型网站需要花费大量时间。因此，每隔5秒，我就会从服务器检索统计信息。现在的问题是我需要在扫描处理完成时（而不是更新期间）最后发送所有List变量数据。现在发生
-
问题内容： 我用来将一些对象作为JSON值返回，并且除了一个字段外，它都工作正常。有没有一种简单的方法可以在一个字段中添加内容而无需手动创建整个json模板？ 问题答案： Play使用GSON构建JSON字符串。如果您的字段是一种特定的对象类型，则可以通过为该类型提供自定义的序列化来轻松完成此操作。在这里查看文档 http://sites.google.com/site/gson/gson-use