public class StreamingPalindromeExample extends Object implements StreamingInstance
A job that searches the supplied file for palindromes. Outputs timing information to another file for benchmarking purposes. References standard palindrom calculation. Uses spark processing for the computations.
Constructor and Description |
---|
StreamingPalindromeExample() |
Modifier and Type | Method and Description |
---|---|
boolean |
execute(JobInput in)
Executes the underlying code for this job.
|
void |
setSparkContext(org.apache.spark.SparkContext context)
Set the context to run by.
|
void |
setStreamingContext(org.apache.spark.streaming.StreamingContext context)
Set the context to run by.
|
public boolean execute(JobInput in) throws JobInputException
JobInstance
execute
in interface JobInstance
in
- The Job's input.JobInputException
- If there was an error handling the JobInput
.public void setStreamingContext(org.apache.spark.streaming.StreamingContext context)
StreamingInstance
setStreamingContext
in interface StreamingInstance
public void setSparkContext(org.apache.spark.SparkContext context)
SparkInstance
setSparkContext
in interface SparkInstance
Copyright © 1999-2015 Apache OODT. All Rights Reserved.