@InterfaceAudience.Public public interface LogicalIOProcessorFrameworkInterface extends ProcessorFrameworkInterface
LogicalInput
s and produces
LogicalOutput
s.
Users are expected to implements AbstractLogicalIOProcessor
Modifier and Type | Method and Description |
---|---|
void |
run(Map<String,LogicalInput> inputs,
Map<String,LogicalOutput> outputs)
Runs the
Processor |
abort, close, handleEvents, initialize
void run(Map<String,LogicalInput> inputs, Map<String,LogicalOutput> outputs) throws Exception
Processor
inputs
- a map of the source vertex name to LogicalInput
- one per
incoming edge.outputs
- a map of the destination vertex name to LogicalOutput
-
one per outgoing edgeException
- TODOCopyright © 2024 Apache Software Foundation. All rights reserved.