K
V
public interface KeyValueCollector<K,V>
Mapper
void
collect(K key, V value)
void collect(K key, V value) throws java.io.IOException, java.lang.InterruptedException
key
value
java.io.IOException
java.lang.InterruptedException