com.asakusafw.runtime.flow

Class MapperWithRuntimeResource<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

java.lang.Object

org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

com.asakusafw.runtime.flow.MapperWithRuntimeResource<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

Type Parameters:

KEYIN - input key type

VALUEIN - input value type

KEYOUT - output key type

VALUEOUT - output value type

Direct Known Subclasses:

AbstractDirectOutputMapper, AbstractNoReduceDirectOutputMapper, PreparatorMapper, SlotDirectMapper, SlotDistributor

public abstract class MapperWithRuntimeResource<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
extends org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

An abstract super class of a mapper with RuntimeResources.

Since:

0.5.1

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.Mapper

org.apache.hadoop.mapreduce.Mapper.Context

Constructor Summary

Constructors

Constructor and Description
MapperWithRuntimeResource()

Method Summary

Modifier and Type	Method and Description
void	run(org.apache.hadoop.mapreduce.Mapper.Context context)
protected void	runInternal(org.apache.hadoop.mapreduce.Mapper.Context context) Invokes Mapper#run(Context) internally.

Methods inherited from class org.apache.hadoop.mapreduce.Mapper

cleanup, map, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

MapperWithRuntimeResource

public MapperWithRuntimeResource()

Method Detail

runInternal

protected void runInternal(org.apache.hadoop.mapreduce.Mapper.Context context)
                    throws IOException,
                           InterruptedException

Invokes Mapper#run(Context) internally. Clients can override this method and implement customized run method.

Parameters:

context - current context

Throws:

IOException - if task is failed by I/O error

InterruptedException - if task execution is interrupted

run

public final void run(org.apache.hadoop.mapreduce.Mapper.Context context)
               throws IOException,
                      InterruptedException

Overrides:

run in class org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>

Throws:

IOException

InterruptedException