public class FlowProcessor extends org.apache.tez.runtime.api.AbstractLogicalIOProcessor
Constructor and Description |
---|
FlowProcessor(org.apache.tez.runtime.api.ProcessorContext context) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
handleEvents(List<org.apache.tez.runtime.api.Event> events) |
void |
initialize() |
void |
run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputMap,
Map<String,org.apache.tez.runtime.api.LogicalOutput> outputMap) |
protected void |
waitForInputsReady(Map<String,org.apache.tez.runtime.api.LogicalInput> inputMap) |
public FlowProcessor(org.apache.tez.runtime.api.ProcessorContext context)
public void initialize() throws Exception
initialize
in interface org.apache.tez.runtime.api.ProcessorFrameworkInterface
initialize
in class org.apache.tez.runtime.api.AbstractLogicalIOProcessor
Exception
public void run(Map<String,org.apache.tez.runtime.api.LogicalInput> inputMap, Map<String,org.apache.tez.runtime.api.LogicalOutput> outputMap) throws Exception
Exception
protected void waitForInputsReady(Map<String,org.apache.tez.runtime.api.LogicalInput> inputMap) throws InterruptedException
InterruptedException
public void handleEvents(List<org.apache.tez.runtime.api.Event> events)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.