public abstract class RecordProcessor extends InterruptibleProcessing
Modifier and Type | Field and Description |
---|---|
protected String |
CLASS_NAME |
protected Map<String,org.apache.tez.runtime.api.LogicalInput> |
inputs |
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 |
createOutputMap() |
List<BaseWork> |
getMergeWorkList(org.apache.hadoop.mapred.JobConf jconf,
String key,
String queryId,
ObjectCache cache,
List<String> cacheKeys) |
abort, addRowAndMaybeCheckAbort, checkAbortCondition, isAborted, setAborted, startAbortChecks
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 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
Copyright © 2022 The Apache Software Foundation. All rights reserved.