在使用自定义处理器的nifi流中以成功关系传递多个文件?
In nifi flow using custom processor pass multiple file in sucess relationship?
如何开发自定义 apache nifi 处理器,该处理器将一个工作簿与多个 sheet 作为输入,每个 sheet 中的行数为每一行生成 json 并传递每个生成的json 成功建立关系。
通常,您使用 processSession.clone()
从原始文件(通过出处数据链接)创建子流文件,并使用 processSession.transfer()
将它们传递给 SUCCESS
关系。您可以在 SplitText
中看到一个很好的例子。
如何开发自定义 apache nifi 处理器,该处理器将一个工作簿与多个 sheet 作为输入,每个 sheet 中的行数为每一行生成 json 并传递每个生成的json 成功建立关系。
通常,您使用 processSession.clone()
从原始文件(通过出处数据链接)创建子流文件,并使用 processSession.transfer()
将它们传递给 SUCCESS
关系。您可以在 SplitText
中看到一个很好的例子。