org.apache.pig.backend.hadoop.executionengine.tez.runtime

Class PigProcessor

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalIOProcessor

org.apache.pig.backend.hadoop.executionengine.tez.runtime.PigProcessor

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 PigProcessor
extends org.apache.tez.runtime.api.AbstractLogicalIOProcessor

Field Summary

Fields

Modifier and Type	Field and Description
static String	COMBINE_PLAN
static String	ESTIMATE_PARALLELISM
static String	ESTIMATED_NUM_PARALLELISM
static String	PLAN
static String	SAMPLE_VERTEX
static Map<String,Object>	sampleMap
static String	sampleVertex
static String	SORT_VERTEX

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	close()
void	handleEvents(List<org.apache.tez.runtime.api.Event> processorEvents)
void	initialize()
void	run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, Map<String,org.apache.tez.runtime.api.LogicalOutput> outputs)
protected void	runPipeline(PhysicalOperator leaf)

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

Field Detail

PLAN

public static final String PLAN

See Also:

Constant Field Values

COMBINE_PLAN

public static final String COMBINE_PLAN

See Also:

Constant Field Values

ESTIMATE_PARALLELISM

public static final String ESTIMATE_PARALLELISM

See Also:

Constant Field Values

ESTIMATED_NUM_PARALLELISM

public static final String ESTIMATED_NUM_PARALLELISM

See Also:

Constant Field Values

SAMPLE_VERTEX

public static final String SAMPLE_VERTEX

See Also:

Constant Field Values

SORT_VERTEX

public static final String SORT_VERTEX

See Also:

Constant Field Values

sampleVertex

public static String sampleVertex

sampleMap

public static Map<String,Object> sampleMap

Constructor Detail

PigProcessor

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

Method Detail

initialize

public void initialize()
                throws Exception

Specified by:

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

Specified by:

initialize in class org.apache.tez.runtime.api.AbstractLogicalIOProcessor

Throws:

Exception

handleEvents

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

close

public void close()
           throws Exception

Throws:

Exception

run

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

Throws:

Exception

runPipeline

protected void runPipeline(PhysicalOperator leaf)
                    throws IOException,
                           InterruptedException

Throws:

IOException

InterruptedException