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

java.lang.Object
  org.apache.hadoop.hive.ql.exec.tez.TezProcessor

All Implemented Interfaces:

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

Direct Known Subclasses:

MapTezProcessor, ReduceTezProcessor

public class TezProcessor
extends Object
implements org.apache.tez.runtime.api.LogicalIOProcessor

Hive processor for Tez that forms the vertices in Tez and processes the data. Does what ExecMapper and ExecReducer does for hive in MR framework.

Constructor Summary

TezProcessor(boolean isMap)

Method Summary

void	close()
void	handleEvents(List<org.apache.tez.runtime.api.Event> arg0)
void	initialize(org.apache.tez.runtime.api.TezProcessorContext processorContext)
void	run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs)

Methods inherited from class java.lang.Object

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

Constructor Detail

TezProcessor

public TezProcessor(boolean isMap)

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.tez.runtime.api.Processor

Throws:

IOException

handleEvents

public void handleEvents(List<org.apache.tez.runtime.api.Event> arg0)

Specified by:

handleEvents in interface org.apache.tez.runtime.api.Processor

initialize

public void initialize(org.apache.tez.runtime.api.TezProcessorContext processorContext)
                throws IOException

Specified by:

initialize in interface org.apache.tez.runtime.api.Processor

Throws:

IOException

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.LogicalIOProcessor

Throws:

Exception