datafu.hourglass.model
Interface Mapper<In,OutKey,OutVal>

Type Parameters:

In - Input type

OutKey - Output key type

OutVal - Output value type

All Superinterfaces:

java.io.Serializable

public interface Mapper<In,OutKey,OutVal>
extends java.io.Serializable

Maps an input record to one or more key-value pairs.

Author:

"Matthew Hayes"

Method Summary

void	map(In input, KeyValueCollector<OutKey,OutVal> collector) Maps an input record to one or more key-value pairs.

Method Detail

map

void map(In input,
         KeyValueCollector<OutKey,OutVal> collector)
         throws java.io.IOException,
                java.lang.InterruptedException

Maps an input record to one or more key-value pairs.

Parameters:

input - Input value

collector - Collects output key-value pairs

Throws:

java.io.IOException

java.lang.InterruptedException