Package | Description |
---|---|
org.kepler.ddp.director | |
org.kepler.hadoop.director | |
org.kepler.spark.director | |
org.kepler.stratosphere.director |
Modifier and Type | Field and Description |
---|---|
protected DDPDirector |
DDPEngine._director
The containing director.
|
Constructor and Description |
---|
DDPEngine(DDPDirector director)
Create a new DDPEngine.
|
Modifier and Type | Class and Description |
---|---|
class |
HadoopDirector
A DDP director that uses the Hadoop engine to convert DDP pattern
actors (Map, Reduce, Cross, CoGroup, and Match) and I/O actors
(DDPDataSink and DDPDataSource) into a Hadoop job and runs it on
the server.
|
Constructor and Description |
---|
HadoopEngine(DDPDirector director) |
Constructor and Description |
---|
SparkEngine(DDPDirector director) |
Modifier and Type | Class and Description |
---|---|
class |
StratosphereDirector
A DDP director that uses the Stratosphere engine to convert DDP pattern
actors (Map, Reduce, Cross, CoGroup, and Match) and I/O actors
(DDPDataSink and DDPDataSource) into a Stratosphere job and runs it on
the server.
|
Constructor and Description |
---|
StratosphereEngine(DDPDirector director)
Create a new StratosphereEngine.
|