hadoop - Map Reduce ジョブに配列を入力するにはどうすればよいですか?

Question

一部のデータを継続的に取得するサービスがあります。このデータを配列にダンプしています。このデータはさらに処理する必要があります。サービスによって更新され続ける動的配列を作成し、並べて Map Reduce ジョブを実行することはできますか? また、（ファイルではなく）配列入力を単純に取得するためにどのクラスを使用すればよいですか？PS Hadoop/Map Reduce は初めてで、Java でコーディングしています。