Constructor and Description |
---|
LocalMapTask(org.apache.hadoop.mapreduce.InputFormat<INKEY,INVALUE> inputFormat,
org.apache.hadoop.mapreduce.OutputFormat<OUTKEY,OUTVALUE> outputFormat,
org.apache.hadoop.conf.Configuration conf,
int id,
org.apache.hadoop.mapreduce.InputSplit split,
ContentPumpReporter reporter,
AtomicInteger pctProgress) |
Modifier and Type | Method and Description |
---|---|
Object |
call() |
Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> |
getMapperClass() |
int |
getThreadCount() |
void |
setMapperClass(Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> runtimeMapperClass) |
void |
setThreadCount(int threads) |
public LocalMapTask(org.apache.hadoop.mapreduce.InputFormat<INKEY,INVALUE> inputFormat, org.apache.hadoop.mapreduce.OutputFormat<OUTKEY,OUTVALUE> outputFormat, org.apache.hadoop.conf.Configuration conf, int id, org.apache.hadoop.mapreduce.InputSplit split, ContentPumpReporter reporter, AtomicInteger pctProgress)
public int getThreadCount()
public void setThreadCount(int threads)
public Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> getMapperClass()
public void setMapperClass(Class<? extends org.apache.hadoop.mapreduce.Mapper<?,?,?,?>> runtimeMapperClass)
Copyright © 2021 MarkLogic Corporation
Complete online documentation for MarkLogic Server, XQuery and related components may be found at developer.marklogic.com