public class SparkDistributor extends Object implements SearchDistributor, Serializable
Constructor and Description |
---|
SparkDistributor(String masterURL)
Sets the master URL
|
Modifier and Type | Method and Description |
---|---|
void |
distribute(List<Frontier> frontierList)
Distributes the list of the problems
|
org.apache.spark.api.java.JavaRDD<Map<String,String>> |
getGeneratedMaps() |
SparkDistributor |
setDataConsumer(DataConsumer dataConsumer)
Sets the data consumer
|
public SparkDistributor(String masterURL)
masterURL
- a String containing master URLpublic SparkDistributor setDataConsumer(DataConsumer dataConsumer)
SearchDistributor
setDataConsumer
in interface SearchDistributor
dataConsumer
- the DataConsumerpublic void distribute(List<Frontier> frontierList)
SearchDistributor
distribute
in interface SearchDistributor
frontierList
- a list containing the search problems to
distributeCopyright © 2016. All rights reserved.