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(java.util.List<org.apache.tez.runtime.api.Event> events) |
void |
initialize() |
void |
run(java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalInput> inputMap,
java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalOutput> outputMap) |
protected void |
waitForInputsReady(java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalInput> inputMap) |
public FlowProcessor(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 run(java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalInput> inputMap, java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalOutput> outputMap) throws java.lang.Exception
java.lang.Exception
protected void waitForInputsReady(java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalInput> inputMap) throws java.lang.InterruptedException
java.lang.InterruptedException
public void handleEvents(java.util.List<org.apache.tez.runtime.api.Event> events)
public void close() throws java.lang.Exception
java.lang.Exception
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.