| 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.
|