cascading.flow
Class FlowMapper

java.lang.Object
  MapReduceBase
      cascading.flow.FlowMapper

public class FlowMapper
extends MapReduceBase

Class FlowMapper ...

Constructor Summary

FlowMapper()
Constructor FlowMapper creates a new FlowMapper instance.

Method Summary

void	close()
void	configure(JobConf jobConf)
void	map(Object key, Object value, OutputCollector output, Reporter reporter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowMapper

public FlowMapper()

Constructor FlowMapper creates a new FlowMapper instance.

Method Detail

configure

public void configure(JobConf jobConf)

map

public void map(Object key,
                Object value,
                OutputCollector output,
                Reporter reporter)
         throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException