2017-03-16 13 views
1

アップストリーム接続からファイルを読み取り、読み取りが完了したらそれを削除するカスタムプロセッサを作成しました。javaで読み込んだ後にファイルを削除するには?

私は、ファイルを削除しよう。持ってここでコード

String input_File="C:\File\Filename.txt"; 
File delete_Files= new File(input_File); 
delete_Files.delete(); 

しかし、私は、Apache Nifi only.If内のファイルを削除することはできません私はそれがファイルを削除することができJava APIの同じことを使用していることができます。

誰でもApache Nifiで読んだ後にファイルを削除するように提案できますか?

答えて

3

プロセッサがsession.get()を使用してアップストリーム接続からフローファイルを受信した場合、session.tansfer(flowfile)を使用してフローファイルを関係に転送して、関係を終了するか、フローファイルを渡したくない場合は、session.remove(flowfile)を呼び出すことができます。

各フローファイルのデータはNiFiの内部リポジトリに保存されており、セッションで適切なAPIを使用することで内部リポジトリとのやりとりができます。

関連する問題