我有一个服务正在不断检索一些数据。我正在将这些数据转储到一个数组中，这些数据需要进一步处理。有没有可能创建一个动态数组，让serivice不断更新，我可以并行地执行map reduce作业？另外，我如何使用哪个类来简单地获取数组输入（而不是文件）？ps我是hadoop/MapReduce的新手，我用java编写代码。