| Package | Description |
|---|---|
| org.kepler.hadoop.execution | |
| org.kepler.spark.stub |
| Modifier and Type | Field and Description |
|---|---|
protected StubSinkActor |
KeplerAppBase._sinkActor
The actor reading output from the workflow.
|
| Modifier and Type | Field and Description |
|---|---|
protected StubSinkActor |
KeplerPairFlatMapFunction._sinkActor
A sink actor used for reading data from the workflow and writing
it to Spark.
|