@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());
}