MudrodEngine { public void startFullIngest() { DiscoveryEngineAbstract wd = new WeblogDiscoveryEngine(props, es, spark); wd.preprocess(); wd.process(); DiscoveryEngineAbstract md = new MetadataDiscoveryEngine(props, es, spark); md.preprocess(); md.process(); DiscoveryEngineAbstract recom = new RecommendEngine(props, es, spark); recom.preprocess(); recom.process(); LOG.info("Full ingest has finished successfully."); } MudrodEngine(); ESDriver startESDriver(); SparkDriver startSparkDriver(); Properties getConfig(); ESDriver getESDriver(); void setESDriver(ESDriver es); Properties loadConfig(); void startLogIngest(); void startMetaIngest(); void startFullIngest(); void startProcessing(); void end(); static void main(String[] args); SparkDriver getSparkDriver(); void setSparkDriver(SparkDriver sparkDriver);  }
@Ignore @Test public final void testStartFullIngest() { fail("Not yet implemented"); }