2
私は、スプーリングディレクトリを持つFlumeエージェントをソースとして実行する必要があります。スプールディレクトリのすべてのファイルがHDFS（シンク）にコピーされた後、すべてのファイルがチャンネルにプッシュされていることを知っているので、エージェントを停止します。 また、毎回異なるスプーリングディレクトリに対してこの手順を実行し、ディレクトリのすべてのファイルが.COMPLETEDとしてマークされているときにエージェントを停止したいとします。 flumeエージェントを停止する方法はありますか？Flumeエージェントを停止する
これはflumeの使用例ではありません – Farooque
Ok.私はレベルを下げることができますか？ 達成しようとしていることを説明しましょう。私はETLのプロセスを持っています。ユーザーが入力ディレクトリを与えると、まずputコマンドを使ってHDFSにコピーし、MapReduceジョブを実行します。putコマンドを使用するよりもHDFSにデータをプッシュする効率的な方法があるかどうかを調べることです。それを達成するためにflumeを探索してください。しかし、問題は、ユーザーが別のディレクトリからデータをロードしたいときにスプールディレクトリが変更されるたびに問題になります。 これはFlumeのユースケースに当てはまりますか？そうでない場合、他のコンポーネントがありますか？ –