T
- target data typepublic abstract class AbstractDirectOutputMapper<T extends DataModel<T>> extends MapperWithRuntimeResource<Object,T,AbstractDirectOutputKey,AbstractDirectOutputValue>
DirectOutputReducer
.Modifier | Constructor and Description |
---|---|
protected |
AbstractDirectOutputMapper(int position,
Class<? extends AbstractDirectOutputKey> keyClass,
Class<? extends AbstractDirectOutputValue> valueClass)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
map(Object key,
T value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
run, runInternal
protected AbstractDirectOutputMapper(int position, Class<? extends AbstractDirectOutputKey> keyClass, Class<? extends AbstractDirectOutputValue> valueClass)
position
- position of target outputkeyClass
- key classvalueClass
- value classprotected void map(Object key, T value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class org.apache.hadoop.mapreduce.Mapper<Object,T extends DataModel<T>,AbstractDirectOutputKey,AbstractDirectOutputValue>
IOException
InterruptedException
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.