SparkDistributor implements SearchDistributor, Serializable { public SparkDistributor(final String masterURL) { this.masterURL = masterURL; } SparkDistributor(final String masterURL); @Override SparkDistributor setDataConsumer(DataConsumer dataConsumer); @Override void distribute(final List<Frontier> frontierList); JavaRDD<Map<String, String>> getGeneratedMaps();  }
@Test public void testSparkDistributor() { InputStream is = SparkDistributorTest.class.getResourceAsStream("/spark/samplemachine.xml"); SCXMLEngine scxmlEngine = new SCXMLEngine(); scxmlEngine.setModelByInputFileStream(is); scxmlEngine.setBootstrapMin(1); SparkDistributor sparkDistributor = new SparkDistributor("local[5]"); scxmlEngine.process(sparkDistributor); JavaRDD<Map<String, String>> results = sparkDistributor.getGeneratedMaps(); Assert.assertEquals(243, results.collect().size()); }