1

hdfsを読み書きするクラスを作成しました。これらのクラスがインスタンス化されるときに発生する特定の条件を前提として、特定のパスとファイルを作成し、それに書き込みます(または、以前に作成されたパスとファイルに移動して、そこから読み取ります)。いくつかのHadoopジョブを実行してテストしましたが、正しく機能しているようです。

ただし、これをJUnitフレームワークでテストできるようにしたいのですが、JUnitでhdfsの読み取りと書き込みをテストできる適切なソリューションが見つかりませんでした。この件について役立つアドバイスをいただければ幸いです。ありがとう。

4

1 に答える 1

3

私はまだこれを試していませんが、あなたが探しているのはorg.apache.hadoop.hdfs.MiniDFSClusterだと思います。

これは、hadoop-core-.jarではなくhadoop-test-.jarにあります。Hadoopプロジェクトはそれを内部的に使用してテストしていると思います。

ここにあります:

http://svn.apache.org/viewvc/hadoop/hdfs/trunk/src/test/hdfs/org/apache/hadoop/hdfs/MiniDFSCluster.java?revision=1127823&view=markup&pathrev=1130381

同じディレクトリにたくさんの用途があると思いますが、ここに1つあります。

http://svn.apache.org/viewvc/hadoop/hdfs/trunk/src/test/hdfs/org/apache/hadoop/hdfs/TestWriteRead.java?revision=1130381&view=markup&pathrev=1130381

于 2011-06-17T23:13:19.877 に答える