public class FlowProcessor extends AbstractLogicalIOProcessor
Constructor and Description |
---|
FlowProcessor(ProcessorContext context) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
handleEvents(java.util.List<Event> events) |
void |
initialize() |
void |
run(java.util.Map<java.lang.String,LogicalInput> inputMap,
java.util.Map<java.lang.String,LogicalOutput> outputMap) |
protected void |
waitForInputsReady(java.util.Map<java.lang.String,LogicalInput> inputMap) |
abort, getContext
public FlowProcessor(ProcessorContext context)
public void initialize() throws java.lang.Exception
initialize
in interface ProcessorFrameworkInterface
initialize
in class AbstractLogicalIOProcessor
java.lang.Exception
public void run(java.util.Map<java.lang.String,LogicalInput> inputMap, java.util.Map<java.lang.String,LogicalOutput> outputMap) throws java.lang.Exception
java.lang.Exception
protected void waitForInputsReady(java.util.Map<java.lang.String,LogicalInput> inputMap) throws java.lang.InterruptedException
java.lang.InterruptedException
public void handleEvents(java.util.List<Event> events)
public void close() throws java.lang.Exception
java.lang.Exception
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.