問題タブ [reducers]

MapReduce アプリケーションの初心者です。私は単にデータセットで単語の長さを見つけようとしており、それらの長さに応じてそれらを小さな、小さな、中、巨大に分類しようとしています。最終的に、小さな、小さな、中の単語の総数を確認したいと思いますまたはJavaのデータセットが巨大ですが、リデューサーの実装に問題があります。Hadoop クラスターで jar ファイルを実行すると、結果が返されません。誰かが私に手を差し伸べてくれたら、私は感謝します。これは私が実行しようとしているレデューサーコードですが、私が推測する多くのエラーがあります。

エラーは発生していません。txtReduceOutputKey これらの変数を開始できるので、クラスにアクセスできますtxtReduceOutputValue。ただし、reduce実行中はメソッドは無視されます。そのため、上記のメソッドの //some コードを実行できません。また、以下のパッケージを使用しています。

どうすればこれを修正できますか？

配列を反復処理して各要素 (合計 2 要素) を割り当てるには、リデューサーが必要です。しかし、私のコードはすべての値を取り、それを単にキーに割り当てていますか?

たとえば、次のとおりです。

このメソッドは、すべての配列を値のバケットにダンプしているだけですか?

While ループを使用して Text[] の各要素を取得し、int に割り当てる方法はありますか?

これが私の始まりです：

これはすべての値を取得して AtBat にしますが、2 番目の要素を Hit にしたいと考えています。これを達成する方法について混乱しています。

次のようにジョブのグローバル変数を設定します。

このようにレデューサーでアクセスし、値を確認しました：

ただし、その値は null として出力されます。

NullPointerException

取得した変数を使用しようとしたときに発生しました

属性

コードの後半。

何が問題なのかを調べるのを手伝ってください。