T
- target data typepublic abstract class AbstractNoReduceDirectOutputMapper<T> extends MapperWithRuntimeResource<Object,T,Object,Object>
Constructor and Description |
---|
AbstractNoReduceDirectOutputMapper(Class<? extends T> dataType,
String rawBasePath,
String rawResourcePath,
Class<? extends DataFormat<? super T>> dataFormatClass)
Creates a new instance.
|
AbstractNoReduceDirectOutputMapper(Class<? extends T> dataType,
String outputId,
String rawBasePath,
String rawResourcePath,
Class<? extends DataFormat<? super T>> dataFormatClass)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
protected void |
runInternal(org.apache.hadoop.mapreduce.Mapper.Context context)
Invokes
Mapper#run(Context) internally. |
run
public AbstractNoReduceDirectOutputMapper(Class<? extends T> dataType, String rawBasePath, String rawResourcePath, Class<? extends DataFormat<? super T>> dataFormatClass)
dataType
- target data typerawBasePath
- target base pathrawResourcePath
- target resource pathdataFormatClass
- output data formatIllegalArgumentException
- if some parameters were null
public AbstractNoReduceDirectOutputMapper(Class<? extends T> dataType, String outputId, String rawBasePath, String rawResourcePath, Class<? extends DataFormat<? super T>> dataFormatClass)
dataType
- target data typeoutputId
- the output ID (nullable)rawBasePath
- target base pathrawResourcePath
- target resource pathdataFormatClass
- output data formatIllegalArgumentException
- if some parameters were null
protected void runInternal(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
MapperWithRuntimeResource
Mapper#run(Context)
internally.
Clients can override this method and implement customized run
method.runInternal
in class MapperWithRuntimeResource<Object,T,Object,Object>
context
- current contextIOException
- if task is failed by I/O errorInterruptedException
- if task execution is interruptedCopyright © 2011–2018 Asakusa Framework Team. All rights reserved.