BasicBatchPipeline implements Pipeline { @Override public Explanation results() throws Exception { long startTime = System.currentTimeMillis(); DataFrame df = loadData(); long elapsed = System.currentTimeMillis() - startTime; log.info("Loading time: {} ms", elapsed); log.info("{} rows", df.getNumRows()); log.info("Metric: {}", metric); log.info("Attributes: {}", attributes); Classifier classifier = getClassifier(); classifier.process(df); df = classifier.getResults(); BatchSummarizer summarizer = getSummarizer(classifier.getOutputColumnName()); startTime = System.currentTimeMillis(); summarizer.process(df); elapsed = System.currentTimeMillis() - startTime; log.info("Summarization time: {} ms", elapsed); Explanation output = summarizer.getResults(); return output; } BasicBatchPipeline(PipelineConfig conf); Classifier getClassifier(); BatchSummarizer getSummarizer(String outlierColumnName); DataFrame loadData(); @Override Explanation results();  }
@Test public void testDemoQuery() throws Exception { PipelineConfig conf = PipelineConfig.fromYamlFile( "src/test/resources/tiny_conf.yaml" ); BasicBatchPipeline p = new BasicBatchPipeline(conf); Explanation e = p.results(); assertEquals(3.0, e.numTotal(), 1e-10); }