Ich habe einen benutzerdefinierten Prozessor erstellt, in dem die Datei von Upstream-Verbindungen gelesen und nach Abschluss des Lesevorgangs gelöscht wird.
Hier Code habe ich versucht, Datei zu löschen.,
String input_File="C:\File\Filename.txt";
File delete_Files= new File(input_File);
delete_Files.delete();
Aber ich kann die Datei nicht nur in Apache Nifi löschen. Wenn ich dasselbe in Java-API verwendet habe, könnte es sich um eine Datei löschen handeln.
Kann mir bitte jemand vorschlagen, die Datei nach dem Einlesen in Apache Nifi zu löschen?
Wenn Ihr Prozessor mithilfe von session.get() eine Flow-Datei von einer Upstream-Verbindung erhält, können Sie die Flow-Datei entweder mit session.tansfer(flowfile) in eine Beziehung übertragen und den Benutzer entscheiden lassen, ob er die Beziehung beenden möchte, Wenn Sie die Flow-Datei nicht weitergeben möchten, können Sie session.remove (flowfile) aufrufen.
Die Daten für jede Flow-Datei werden in den internen Repositorys von NiFi gespeichert und Sie können nur mit den internen Repositorys interagieren, indem Sie die entsprechenden APIs in der Sitzung verwenden.
Dieser Artikel stammt aus dem Internet. Bitte geben Sie beim Nachdruck die Quelle an.
Bei Verstößen wenden Sie sich bitte [email protected] Löschen.
Lass mich ein paar Worte sagen