2011年3月30日 星期三

Map & Reduce class variable

經過測試 Map 和 Reduce 的 Class variable 只會維持在同一個 Job 中
一出 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)

大家不妨可以試試

沒有留言:

張貼留言