| Package | Description |
|---|---|
| org.kepler.ddp.actor.pattern.stub | |
| org.kepler.hadoop.execution | |
| org.kepler.spark.stub |
| 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.
|
| Modifier and Type | Field and Description |
|---|---|
protected StubSourceActor |
KeplerAppBase._sourceActor
The actor writing input to the workflow.
|
| Modifier and Type | Field and Description |
|---|---|
protected StubSourceActor |
KeplerPairFlatMapFunction._sourceActor
A source actor used for reading data from Spark and writing
it the Kepler workflow.
|