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

Class MergeFileTezProcessor

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalIOProcessor

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

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

All Implemented Interfaces:

org.apache.tez.runtime.api.LogicalIOProcessor, org.apache.tez.runtime.api.LogicalIOProcessorFrameworkInterface, org.apache.tez.runtime.api.Processor, org.apache.tez.runtime.api.ProcessorFrameworkInterface

public class MergeFileTezProcessor
extends TezProcessor

Tez processor for fast file merging. This is same as TezProcessor except it has different record processor.

Field Summary

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

isMap, jobConf, jobIdFormat, processorContext, rproc, taskIdFormat

Constructor Summary

Constructors

Constructor and Description
MergeFileTezProcessor(org.apache.tez.runtime.api.ProcessorContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs)

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

close, handleEvents, initialize, initializeAndRunProcessor

Methods inherited from class org.apache.tez.runtime.api.AbstractLogicalIOProcessor

getContext

Methods inherited from class java.lang.Object

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

Constructor Detail

MergeFileTezProcessor

public MergeFileTezProcessor(org.apache.tez.runtime.api.ProcessorContext context)

Method Detail

run

public void run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs,
       Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs)
         throws Exception

Specified by:

run in interface org.apache.tez.runtime.api.LogicalIOProcessorFrameworkInterface

Overrides:

run in class TezProcessor

Throws:

Exception