public class PigProcessor
extends org.apache.tez.runtime.api.AbstractLogicalIOProcessor
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 and Description |
---|
PigProcessor(org.apache.tez.runtime.api.ProcessorContext context) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
handleEvents(java.util.List<org.apache.tez.runtime.api.Event> processorEvents) |
void |
initialize() |
void |
run(java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalInput> inputs,
java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalOutput> outputs) |
protected void |
runPipeline(PhysicalOperator leaf) |
public static final java.lang.String PLAN
public static final java.lang.String COMBINE_PLAN
public static final java.lang.String ESTIMATE_PARALLELISM
public static final java.lang.String ESTIMATED_NUM_PARALLELISM
public static final java.lang.String SAMPLE_VERTEX
public static final java.lang.String SORT_VERTEX
public static java.lang.String sampleVertex
public static java.util.Map<java.lang.String,java.lang.Object> sampleMap
public PigProcessor(org.apache.tez.runtime.api.ProcessorContext context)
public void initialize() throws java.lang.Exception
initialize
in interface org.apache.tez.runtime.api.ProcessorFrameworkInterface
initialize
in class org.apache.tez.runtime.api.AbstractLogicalIOProcessor
java.lang.Exception
public void handleEvents(java.util.List<org.apache.tez.runtime.api.Event> processorEvents)
public void close() throws java.lang.Exception
java.lang.Exception
public void run(java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalInput> inputs, java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalOutput> outputs) throws java.lang.Exception
java.lang.Exception
protected void runPipeline(PhysicalOperator leaf) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
Copyright © 2007-2012 The Apache Software Foundation