使用registerTypeWithKryoSerializer的Flink自定义序列化
让我知道你的想法，并祝贺这一惊人的作品。在以前的项目中，我们确实使用了storm或spark流媒体，但Flink在实时流媒体分析方面遥遥领先。
谢谢，继续努力！
共有1个答案
因此，当前的快速解决方案是确保您的对象不是POJO。在其他情况下，它们不是通过GenericType序列化的，后者使用Kryo并看到您的自定义序列化器。
当您遇到此类问题时，非常有用的调试方法是：env.getConfig（）.disableGenericTypes（）；
允许在异常情况下停止任务启动，允许检查使用了哪种序列化程序和HintTypes。
-
问题内容： 我有一堂课 我想将下面的JSON数据反序列化到上面的类/对象中 我的想法是在JSON中是一个对象，但我只想获取（在JSON中）在反序列化期间将像在类中那样传递。 如何使用Json.NET实现该目标？ 我相信我可以使用CustomJsonConverter完成它。但是我很困惑。docs中的示例仅用于，但不适用。 问题答案： 我只是使用上面在问题中提到的方法解决了我的问题。在我完整的代码下
-
easyopen序列化使用fastjson处理json，xstream处理xml。现在我们来自定义实现一个json处理： 新建一个类JsonFormatter，实现ResultSerializer接口 public class JsonFormatter implements ResultSerializer { @Override public String serialize(
-
问题内容： 我正在使用Flickr API 。调用该方法时，默认的JSON结果为： 我想将此响应解析为Java对象： JSON属性应按以下方式映射： 不幸的是，我无法找到一种使用Annotations做到这一点的好方法。到目前为止，我的方法是将JSON字符串读入a 并从中获取值。 但是我认为，这是有史以来最不优雅的方式。有没有简单的方法，可以使用注释还是自定义反序列化器？ 这对我来说将是很明显的，
-
问题内容： 我正在尝试创建将影响序列化值的自定义杰克逊注释。 含义： 现在序列化对象X（10）将导致： 我该如何实现？ 问题答案： 结果：
-
问题内容： 我有一个需要序列化为XML的对象，其中包含以下字段： XStream可以很好地序列化它（在使用一些别名之后），如下所示： 就目前而言还可以，但是我希望能够将元素重命名为。从XStream站点上的别名文档中，我看不到一种明显的方法。我是否缺少明显的东西？ 问题答案： 我建议将更改为，其中Tag是本质上仅包含字符串的域对象。然后你说： 您将得到您想要的。这样可以避免滚动自己的Convert
-
问题内容： 我在使用Gson解析JSON响应时遇到问题。 JSON字串： 我有这两个课程： 但是当使用Gson解析这个时我有一个异常。我知道这是因为响应数组的第一个元素不是对象，而是整数。 所以问题是，我能以某种方式解决它吗？ 问题答案： 您必须编写一个 自定义反序列化器 。我会做这样的事情： 首先，您需要包括一个新的类，而不是已有的两个类： 然后，您需要一个自定义解串器，类似于以下内容： 然后，