KEYIN
- VALUEIN
- KEYOUT
- VALUEOUT
- public class BaseMapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
extends org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
BaseMapper() |
Modifier and Type | Method and Description |
---|---|
int |
getRequiredThreads() |
void |
run(org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
runThreadSafe(org.apache.hadoop.mapreduce.Mapper.Context outerCtx,
org.apache.hadoop.mapreduce.Mapper.Context subCtx) |
List<Future<Object>> |
submitTasks(ExecutorService threadPool,
org.apache.hadoop.mapreduce.InputSplit inputSplit) |
public void runThreadSafe(org.apache.hadoop.mapreduce.Mapper.Context outerCtx, org.apache.hadoop.mapreduce.Mapper.Context subCtx) throws IOException, InterruptedException
IOException
InterruptedException
public int getRequiredThreads()
public List<Future<Object>> submitTasks(ExecutorService threadPool, org.apache.hadoop.mapreduce.InputSplit inputSplit)
public void run(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
run
in class org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
IOException
InterruptedException
Copyright © 2020 MarkLogic Corporation
Complete online documentation for MarkLogic Server, XQuery and related components may be found at developer.marklogic.com