Implementing an algebraic function
Tuesday, March 01, 2011
9:45 AM
Implementing an algebraic function: 
// map step
static public class Initial extends EvalFunc<Tuple> {
public Tuple exec(Tuple input) {
...
}
}
// combine step
static public class Intermed extends EvalFunc<Tuple> {
   public Tuple exec(Tuple input) throws IOException {
...
}
}
// reduce step
static public class Final extends EvalFunc<Long> {
   public Long exec(Tuple input) {
...
}
}