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