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