Mapperクラスへの変数の送信

Question

ユーザからの入力を取得し、作成したマッパークラスに渡そうとしていますが、ユーザが入力した実際の値を使用する代わりに常に値がゼロに初期化されます。

変数を取得するたびに常に同じ値を保持するようにするにはどうすればよいですか。私はjob1.setMapperClass（Parallel_for.class）に気付きました。クラスのインスタンスを作成し、変数を強制的に元の値に再初期化します。以下は2つのクラスへのリンクです。 RunnerToolクラスから時間の価値を得ようとしています。

Link to Java TestFor class

Link to RunnerTool class

マッパー

@Override 
public void setup(Context context) { 
    int defaultValue = 1; 
    times = context.getConfiguration().getInt("parallel_for_iteration", defaultValue); 
    LOG.info(context.getConfiguration().get("parallel_for_iteration") + " Actually name from the commandline"); 
    LOG.info(times + " Actually number of iteration from the commandline"); 
} 

// RunnerToolsクラスの//設定方法

conf.setInt（反復回数）。

Answer 1

Mapper getはリフレクションによって初期化されるため、ユーザーはマッパークラスと対話できません。

代わりにConfigurationオブジェクトがあります。これは、ジョブを設定する場合に指定する必要があります。ここでは、conf.set("YOUR KEY", "YOUR VALUE")を使用して設定できます。 Mapperクラスでは、setup(Context context)というメソッドをオーバーライドできます。context.getConfiguration().get("YOUR KEY")を使用して値を取得できます。そして、マッパーのローカル変数に保存することもできます。

Answer 2

マッパークラスは多くのクラスターノードで再作成されるので、ジョブ実行時にマッパークラスのインスタンスに対して行われた初期化は他のノードに影響しないので注意してください。技術的に関連性のあるjarファイルはノード間で配布され、そこでマッパーが作成されます。 上記の答えで指摘されているように、マッパーに情報を渡す唯一の方法は、Configurationクラスを使用することです。