org.apache.hadoop.hive.ql.exec.tez

Class MapRecordProcessor

java.lang.Object

org.apache.hadoop.hive.ql.exec.tez.RecordProcessor

org.apache.hadoop.hive.ql.exec.tez.MapRecordProcessor

public class MapRecordProcessor
extends RecordProcessor

Process input from tez LogicalInput and write output - for a map plan Just pump the records through the query plan.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	l4j
protected static String	MAP_PLAN_KEY

Fields inherited from class org.apache.hadoop.hive.ql.exec.tez.RecordProcessor

CLASS_NAME, inputs, isLogInfoEnabled, isLogTraceEnabled, jconf, outMap, outputs, perfLogger, processorContext, reporter

Constructor Summary

Constructors

Constructor and Description
MapRecordProcessor(org.apache.hadoop.mapred.JobConf jconf, org.apache.tez.runtime.api.ProcessorContext context)

Method Summary

Methods inherited from class org.apache.hadoop.hive.ql.exec.tez.RecordProcessor

createOutputMap, getMergeWorkList

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

l4j

public static final org.apache.commons.logging.Log l4j

MAP_PLAN_KEY

protected static final String MAP_PLAN_KEY

See Also:

Constant Field Values

Constructor Detail

MapRecordProcessor

public MapRecordProcessor(org.apache.hadoop.mapred.JobConf jconf,
                  org.apache.tez.runtime.api.ProcessorContext context)
                   throws Exception

Throws:

Exception