Package | Description |
---|---|
org.kepler.ddp.actor.pattern | |
org.kepler.ddp.director | |
org.kepler.hadoop.util | |
org.kepler.spark.director | |
org.kepler.stratosphere.director |
Modifier and Type | Class and Description |
---|---|
class |
CoGroup
An actor for the CoGroup DDP pattern.
|
class |
Cross
An actor for the Cross DDP pattern.
|
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.
|
Modifier and Type | Field and Description |
---|---|
protected static java.util.Map<java.lang.String,SingleInputPatternActor> |
DDPEngine._subWorkflows
A mapping of model name to model.
|
Modifier and Type | Method and Description |
---|---|
SingleInputPatternActor |
DDPPatternActorUtil.getActor() |
Modifier and Type | Method and Description |
---|---|
void |
DDPPatternActorUtil.setActor(SingleInputPatternActor actor) |
Constructor and Description |
---|
DDPPatternActorUtil(SingleInputPatternActor actor,
java.lang.String name,
java.lang.String actorString,
java.util.Map<java.lang.String,Type> typeMap) |
DDPPatternActorUtil(SingleInputPatternActor actor,
java.lang.String name,
java.lang.String impClass,
java.lang.String inputKeyValueType,
java.lang.String outputKeyValueType) |
Modifier and Type | Method and Description |
---|---|
protected void |
SparkEngine._addSubModelToContract(SingleInputPatternActor pactor,
Operator contract)
Write the sub-workflow of a SingleInputPatternActor either to a parameter
in the Spark job configuration or to a file.
|
Modifier and Type | Method and Description |
---|---|
protected void |
StratosphereEngine._addSubModelToContract(SingleInputPatternActor pactor,
eu.stratosphere.api.common.operators.Operator contract)
Write the sub-workflow of a SingleInputPatternActor either to a parameter
in the PACT plan configuration or to a file.
|