@InterfaceAudience.LimitedPrivate(value="MapReduce")
@InterfaceStability.Unstable
public interface MapOutputCollector<K,V>
Modifier and Type | Interface and Description |
---|---|
static class |
MapOutputCollector.Context |
void init(MapOutputCollector.Context context) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
void collect(K key, V value, int partition) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
void close() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
void flush() throws java.io.IOException, java.lang.InterruptedException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.InterruptedException
java.lang.ClassNotFoundException
Copyright © 2009 The Apache Software Foundation