文件未發現異常

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();