Hi all,
most of the time, we focus on the map function to decide whether to output a
record and what to output. Now I want to do something at the map task level. I
want to output a record when a map task finish and this record should be
processed by reducer properly. Is there any way to output (like output.collect
in map function) a record outside map function?
If that is impossible, to know whether I meet the last line for this map task
is also helpful. Does anyone know how to tell whether the line I am processing
now in map function is the last line for this map task?
Thanks.
-Gang
___________________________________________________________
好玩贺卡等你发，邮箱贺卡全新上线！
http://card.mail.cn.yahoo.com/
