Package | Description |
---|---|
org.kepler.ddp | |
org.kepler.ddp.actor.pattern.stub |
Modifier and Type | Method and Description |
---|---|
static Manager |
Utilities.createManagerForModel(CompositeActor model,
ExecutionListener listener,
StubBaseActor stubSource,
StubBaseActor stubSink,
boolean runWorkflowLifecyclePerInput,
boolean enablePrintTimeAndMemory)
Create a Manager for a model and optionally start execution.
|
Modifier and Type | Class and Description |
---|---|
class |
CoGroupInput
A stub actor that writes data into workflows for the CoGroup pattern.
|
class |
CrossInput
A stub actor that writes data into workflows for the Cross pattern.
|
class |
MapInput
A stub actor that writes data into workflows for the Map pattern.
|
class |
MatchInput
A stub actor that writes data into workflows for the Match pattern.
|
class |
ReduceInput
A stub actor that writes data into workflows for the Reduce pattern.
|
class |
StubSinkActor
A base class for DDP pattern actor stubs that read data from the workflow.
|
class |
StubSourceActor
A base class for DDP pattern actor stubs that write data to the workflow.
|