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

Class PigProcessor

java.lang.Object

AbstractLogicalIOProcessor

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

public class PigProcessor
extends AbstractLogicalIOProcessor

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
PigProcessor(ProcessorContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	handleEvents(java.util.List<Event> processorEvents)
void	initialize()
void	run(java.util.Map<java.lang.String,LogicalInput> inputs, java.util.Map<java.lang.String,LogicalOutput> outputs)
protected void	runPipeline(PhysicalOperator leaf)

Methods inherited from class java.lang.Object

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

Field Detail

PLAN

public static final java.lang.String PLAN

See Also:

Constant Field Values

COMBINE_PLAN

public static final java.lang.String COMBINE_PLAN

See Also:

Constant Field Values

ESTIMATE_PARALLELISM

public static final java.lang.String ESTIMATE_PARALLELISM

See Also:

Constant Field Values

ESTIMATED_NUM_PARALLELISM

public static final java.lang.String ESTIMATED_NUM_PARALLELISM

See Also:

Constant Field Values

SAMPLE_VERTEX

public static final java.lang.String SAMPLE_VERTEX

See Also:

Constant Field Values

SORT_VERTEX

public static final java.lang.String SORT_VERTEX

See Also:

Constant Field Values

sampleVertex

public static java.lang.String sampleVertex

sampleMap

public static java.util.Map<java.lang.String,java.lang.Object> sampleMap

Constructor Detail

PigProcessor

public PigProcessor(ProcessorContext context)

Method Detail

initialize

public void initialize()
                throws java.lang.Exception

Throws:

java.lang.Exception

handleEvents

public void handleEvents(java.util.List<Event> processorEvents)

close

public void close()
           throws java.lang.Exception

Throws:

java.lang.Exception

run

public void run(java.util.Map<java.lang.String,LogicalInput> inputs,
       java.util.Map<java.lang.String,LogicalOutput> outputs)
         throws java.lang.Exception

Throws:

java.lang.Exception

runPipeline

protected void runPipeline(PhysicalOperator leaf)
                    throws java.io.IOException,
                           java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException