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.

Method Summary

Methods

Modifier and Type	Method and Description
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 - IOException

java.lang.InterruptedException - InterruptedException