文件未发现异常

Question

我想flowfile其中是XML组件和更新tagvalue之一，我做这里面的自定义nifi处理器的代码，我有这样的代码：

flowFile = session.putAttribute(flowFile,"filename",file.getName() + ".xml"); 
       InputSource inputSource = new InputSource((InputStream) flowFile); 
       DocumentBuilderFactory builderFactory = DocumentBuilderFactory.newInstance(); 
       DocumentBuilder builder = builderFactory.newDocumentBuilder(); 
       Document xmlDocument = builder.parse(inputSource); 
       XPath xPath = XPathFactory.newInstance().newXPath(); 
       NodeList myNodeList = (NodeList) xPath.compile("//runAs/text()") 
         .evaluate(flowFile, XPathConstants.NODESET); 
       myNodeList.item(0).setNodeValue("false"); 

但trows文件未发现异常异常，我应该改变什么使这段代码工作ps我不能使用流文件的路径

Answer 1

nifi流文件不是InputStream。

所以代码(InputStream) flowFile是错误的

，如果你想获得流量文件作为输入流的内容，你可以使用session.read方法是这样的：

InputStream ffStream = session.read(flowFile); 
...do something with stream 
ffStream.close();