java – Apache NiFi：同时输出到多个FlowFiles？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – Apache NiFi：同时输出到多个FlowFiles？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1153字，纯文字阅读大概需要2分钟。

内容图文

有没有办法在NiFi的自定义处理器中同时写入不同的流？例如,我有第三方库使用API??进行重要处理,这些API的工作方式如下：

public void process(InputStream in, OutputStream foo, OutputStream baa, List<String> args)
{
    ...
    foo.write(things);
    baa.write(stuff);
    ...
}

但我能找到的唯一例子都只使用一个输出流：

FlowFile transform = session.write(original, new OutputStreamCallback() {
        @Override
        public void process(OutputStream out) throws IOException {
            out.write("stuff");
        }
    });

处理是分批进行的(由于其规模很大),因此执行所有处理不可行,然后写出单独的流程.

我能想出的唯一方法是多次处理输入:(

为了澄清,我想使用session.write(flowfile,callback)方法写入多个FlowFiles,因此可以单独发送/管理不同的流

解决方法:

NiFi API基于一次处理一个流文件,但您应该能够执行以下操作：

        FlowFile flowFile1 = session.create();
        final AtomicReference<FlowFile> holder = new AtomicReference<>(session.create());

        flowFile1 = session.write(flowFile1, new OutputStreamCallback() {
            @Override
            public void process(OutputStream out) throws IOException {

                FlowFile flowFile2 = session.write(holder.get(), new OutputStreamCallback() {
                    @Override
                    public void process(OutputStream out) throws IOException {

                    }
                });
                holder.set(flowFile2);

            }
        });

内容总结

以上是互联网集市为您收集整理的java – Apache NiFi：同时输出到多个FlowFiles？全部内容，希望文章能够帮你解决java – Apache NiFi：同时输出到多个FlowFiles？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端