java - 如何将复杂的java对象(嵌套映射和列表)从一个apache nifi处理器传递到另一个?

标签 java apache-nifi

我有两个功能要通过自定义 nifi 处理器来实现。第一个的输出被输入到第二个。然而,此输出采用复杂的 java 对象(嵌套 HashMap 和列表)的形式。如果我要将这两个功能实现为单独的处理器,那么如何在两个处理器之间传递这些复杂的 java 对象。我是否必须将它们转换为某种中间形式(例如 json 或 xml),然后从一个处理器传递到另一个处理器(然后在第二个处理器中再次将 json/xml 转换回嵌套映射和列表)?或者还有其他一些我完全错过的标准/明显的方法吗?

PS:目前,我最终将这两个功能放在同一个处理器中,这样我就不必将第一个功能的输出传递给另一个功能。

最佳答案

您应该能够序列化数据 ( https://docs.oracle.com/javase/tutorial/jndi/objects/serial.html ) 并将其通过 FlowFile 传递。

关于java - 如何将复杂的java对象(嵌套映射和列表)从一个apache nifi处理器传递到另一个?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56077105/

相关文章:

Java : Create new ArrayLists based on some condition from existing ArrayList

java - Java 中奇怪的 ClassCastException

java - 使用 KafkaAvroDecoder 将 Avro 消息反序列化为特定数据

java - Java中继承的同一个对象中具有相同身份的两个不同变量

apache-nifi - 在将流文件移动到 NiFi 中的下一个处理器之前引入时间延迟

azure - 如何集成 Apache NiFi 和 Azure Active Directory 进行用户身份验证?

apache-nifi - 阻止(或剥离)FlowFile 内容

java - fragment UI 元素为空

nginx - 带有 Nginx 反向代理的 NiFi 身份验证

apache-nifi - 调试复杂 NiFi 数据流的理想方式