我很难想象流在IO中到底意味着什么。我将流想象为来自文件、套接字或任何其他数据源的连续数据流。对吗?但随后我对我们的java程序如何对流做出反应感到困惑,因为当我们编写任何java代码时,让我们说:上面的java代码不是希望整个对象在被处理之前都存在吗现在让我们假设我们正在从一个流中读取类似于
FileInputStream in = new FileInputStrea
我对Nifi很陌生,我正试图在Nifi中运行一个java应用程序,这是一个更好的方法。构建java Jar并使用ExecuteProcess处理器或构建自定义处理器执行java Jar
我尝试过的方法:我的Nifi流中的第一个处理器是ExecuteProcess。我构建的java生成元素集合,打印集合,然后ExecuteProcess处理器将该集合条目写入输出流文件,使其可供下一个处理</e