Package | Description |
---|---|
org.kepler.ddp.actor.pattern | |
org.kepler.ddp.director | |
org.kepler.hadoop.director |
Modifier and Type | Class and Description |
---|---|
class |
AtomicPathActor
An atomic DDP pattern actor with a path parameter.
|
class |
AtomicPatternActor
An atomic actor for DDP patterns.
|
class |
CoGroup
An actor for the CoGroup DDP pattern.
|
class |
Cross
An actor for the Cross DDP pattern.
|
class |
DDPDataSink
This actor writes data to the storage system for a DDP workflow.
|
class |
DDPDataSource
This actor reads data from the storage system into downstream DDP
pattern actors.
|
class |
DualInputPatternActor
A DDP pattern composite actor with two inputs.
|
class |
Map
An actor for the Map DDP pattern.
|
class |
Match
An actor for the Match DDP pattern.
|
class |
Reduce
An actor for the Reduce DDP pattern.
|
class |
SingleInputPatternActor
A DDP pattern composite actor with a single input.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DDPEngine._copyParameters(DDPPatternActor sourceSubWorkflow,
DDPPatternActor destSubWorkflow)
Copy the workflow parameters from one sub-workflow to another including
the parameters in all the containers of the source.
|
protected java.util.Map<java.lang.String,Type> |
DDPEngine._setPortTypes(DDPPatternActor actor)
Set the port types inside a cloned pattern actor.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<java.lang.String,Type> |
HadoopEngine._setPortTypes(DDPPatternActor actor)
Set the port types inside a cloned pattern actor.
|