创建新的流文件或重用旧的流文件

public void onTrigger(ProcessContext context, ProcessSession session) throws ProcessException {
  FlowFile flowFile = session.get();
  if (flowFile == null) return;

  session.write(
             flowFile,
             (input, output) -> input.transferTo(output) // Do transfomration here
  );
  session.transfer(REL_SUCCESS, flowFile);
}

如果我是对的,那么我在那里做的就是用内容的标识替换原始流文件的内容。

session.create(flowFile);

创建一个新的流文件。

这让我想,我是否做错了,写在原始的流文件中。做起来很简单,所以感觉很好。但也许最好创建一个新的流文件?

这将是一些代码,用于创建新的流文件,并写入原始流文件的内容:

public void onTrigger(ProcessContext context, ProcessSession session) throws ProcessException {
  FlowFile flowFile = session.get();
  if (flowFile == null) return;

  FlowFile newFile = session.create(flowFile);
  session.write(
             newFile,
             output) -> session.read(flowFile).transferTo(output) // Do transfomration here
  );
  session.transfer(REL_SUCCESS, newFile);
}