public abstract class RecordProcessor extends Object
Modifier and Type | Field and Description |
---|---|
protected boolean |
abort |
protected static int |
CHECK_INTERRUPTION_AFTER_ROWS |
protected String |
CLASS_NAME |
protected Map<String,org.apache.tez.runtime.api.LogicalInput> |
inputs |
protected boolean |
isLogInfoEnabled |
protected boolean |
isLogTraceEnabled |
protected org.apache.hadoop.mapred.JobConf |
jconf |
static org.slf4j.Logger |
l4j |
protected Map<String,org.apache.hadoop.mapred.OutputCollector> |
outMap |
protected Map<String,org.apache.tez.runtime.api.LogicalOutput> |
outputs |
protected PerfLogger |
perfLogger |
protected org.apache.tez.runtime.api.ProcessorContext |
processorContext |
protected org.apache.tez.mapreduce.processor.MRTaskReporter |
reporter |
Constructor and Description |
---|
RecordProcessor(org.apache.hadoop.mapred.JobConf jConf,
org.apache.tez.runtime.api.ProcessorContext processorContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkAbortCondition() |
protected void |
createOutputMap() |
List<BaseWork> |
getMergeWorkList(org.apache.hadoop.mapred.JobConf jconf,
String key,
String queryId,
ObjectCache cache,
List<String> cacheKeys) |
protected static final int CHECK_INTERRUPTION_AFTER_ROWS
protected final org.apache.hadoop.mapred.JobConf jconf
protected final org.apache.tez.runtime.api.ProcessorContext processorContext
public static final org.slf4j.Logger l4j
protected volatile boolean abort
protected boolean isLogInfoEnabled
protected boolean isLogTraceEnabled
protected org.apache.tez.mapreduce.processor.MRTaskReporter reporter
protected PerfLogger perfLogger
protected String CLASS_NAME
public RecordProcessor(org.apache.hadoop.mapred.JobConf jConf, org.apache.tez.runtime.api.ProcessorContext processorContext)
protected void createOutputMap()
public List<BaseWork> getMergeWorkList(org.apache.hadoop.mapred.JobConf jconf, String key, String queryId, ObjectCache cache, List<String> cacheKeys) throws HiveException
HiveException
protected void checkAbortCondition() throws InterruptedException
InterruptedException
Copyright © 2016 The Apache Software Foundation. All rights reserved.