一出 Job 後Map 和 Reduce的Class variable 就不會再存在
For example:
我們寫了一個Reduce class
public class TEST_Reduce extends Reducer{
private double[][] C = null;
public void reduce(Text key, Iterable values, Context context)
throws IOException, InterruptedException{
if (C == null){
C = new double[r_int][];
context.write(new Text("Read C"),new Text("1")); }
}
}
這個程式 在同一個Job中 不管Reduce收到多少keys,都只會output一次(Read C,1)
但是若重覆跑 N 次 Job 就會輸出 N 次(Read C,1)
大家不妨可以試試
沒有留言:
張貼留言