Nifi: In Flowfile schreiben

Question

Ich versuche, in Nifi die Flowfile zu schreiben, indem ich groovy mit outputStream (das ist ein bytearrayoutputstream). Die Größe, die ich in das Flowfile schreibe, ist jedoch null. Tue ich es falsch? Danke im Voraus.

Code: FlowFile newFlowFile = sess.create();

newFlowFile = sess.write(newFlowFile, { out -> 
    outputStream 
} as OutputStreamCallback) 

Answer 1

wenn die outputStream ist ein ByteArrayOutputStream dann können Sie ByteArrayOutputStream.writeTo(stream) Methode verwenden, um Inhalte Ihrer bytearray anderen Ausgabestrom zu schreiben.

newFlowFile = sess.write(newFlowFile, { out -> 
    outputStream.writeTo(out) 
} as OutputStreamCallback)