com.asakusafw.runtime.stage.directio

Class AbstractDirectOutputMapper<T extends DataModel<T>>

java.lang.Object

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

com.asakusafw.runtime.flow.MapperWithRuntimeResource<Object,T,AbstractDirectOutputKey,AbstractDirectOutputValue>

com.asakusafw.runtime.stage.directio.AbstractDirectOutputMapper<T>

Type Parameters:

T - target data type

public abstract class AbstractDirectOutputMapper<T extends DataModel<T>>
extends MapperWithRuntimeResource<Object,T,AbstractDirectOutputKey,AbstractDirectOutputValue>

An abstract implementation of each mapper class for direct output. This writes output for DirectOutputReducer.

Since:

0.2.5

Version:

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

Modifier	Constructor and Description
protected	AbstractDirectOutputMapper(int position, Class<? extends AbstractDirectOutputKey> keyClass, Class<? extends AbstractDirectOutputValue> valueClass) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
protected void	map(Object key, T value, org.apache.hadoop.mapreduce.Mapper.Context context)

Methods inherited from class com.asakusafw.runtime.flow.MapperWithRuntimeResource

run, runInternal

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

cleanup, setup

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractDirectOutputMapper

protected AbstractDirectOutputMapper(int position,
                                     Class<? extends AbstractDirectOutputKey> keyClass,
                                     Class<? extends AbstractDirectOutputValue> valueClass)

Creates a new instance.

Parameters:

position - position of target output

keyClass - key class

valueClass - value class

Method Detail

map

protected void map(Object key,
                   T value,
                   org.apache.hadoop.mapreduce.Mapper.Context context)
            throws IOException,
                   InterruptedException

Overrides:

map in class org.apache.hadoop.mapreduce.Mapper<Object,T extends DataModel<T>,AbstractDirectOutputKey,AbstractDirectOutputValue>

Throws:

IOException

InterruptedException