| Package | Description |
|---|---|
| org.kepler.spark.director | |
| org.kepler.spark.operator |
| Modifier and Type | Method and Description |
|---|---|
void |
SparkJob.addDataSink(DataSink operator)
Add a sink operator to the job.
|
| Constructor and Description |
|---|
SparkJob(org.apache.spark.api.java.JavaSparkContext context,
DataSink operator,
java.lang.String name)
Create a new job.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FileDataSink
A data sink that writes to files.
|
class |
NullSink
A data sink that does not write to anything.
|
class |
TokenSink
A data sink that writes to Ptolemy tokens.
|