org.apache.hadoop.mapred

Interface MapOutputCollector<K,V>

All Known Implementing Classes:

MapTask.MapOutputBuffer

@InterfaceAudience.LimitedPrivate(value="MapReduce")
@InterfaceStability.Unstable
public interface MapOutputCollector<K,V>

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	MapOutputCollector.Context

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	collect(K key, V value, int partition)
void	flush()
void	init(MapOutputCollector.Context context)

Method Detail

init

void init(MapOutputCollector.Context context)
          throws java.io.IOException,
                 java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

collect

void collect(K key,
           V value,
           int partition)
             throws java.io.IOException,
                    java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

close

void close()
           throws java.io.IOException,
                  java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

flush

void flush()
           throws java.io.IOException,
                  java.lang.InterruptedException,
                  java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.InterruptedException

java.lang.ClassNotFoundException