VALUE
- public class DocumentMapper<VALUE> extends BaseMapper<DocumentURI,VALUE,DocumentURI,VALUE>
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.mapreduce.Counter |
attemptedCount |
static org.apache.commons.logging.Log |
LOG |
protected org.apache.hadoop.mapreduce.Counter |
readCount |
Constructor and Description |
---|
DocumentMapper() |
Modifier and Type | Method and Description |
---|---|
void |
map(DocumentURI uri,
VALUE fileContent,
org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
getRequiredThreads, run, runThreadSafe, submitTasks
public static final org.apache.commons.logging.Log LOG
protected org.apache.hadoop.mapreduce.Counter readCount
protected org.apache.hadoop.mapreduce.Counter attemptedCount
public void map(DocumentURI uri, VALUE fileContent, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class org.apache.hadoop.mapreduce.Mapper<DocumentURI,VALUE,DocumentURI,VALUE>
IOException
InterruptedException
public void setup(org.apache.hadoop.mapreduce.Mapper.Context context)
setup
in class org.apache.hadoop.mapreduce.Mapper<DocumentURI,VALUE,DocumentURI,VALUE>
Copyright © 2020 MarkLogic Corporation
Complete online documentation for MarkLogic Server, XQuery and related components may be found at developer.marklogic.com