@Test
public void testSimple() throws Exception {

    MacroBaseConf conf = new MacroBaseConf();
    conf.set(MacroBaseConf.CSV_INPUT_FILE, "src/test/resources/data/simple.csv");
    conf.set(MacroBaseConf.ATTRIBUTES, Lists.newArrayList("A2","A5"));
    conf.set(MacroBaseConf.METRICS, Lists.newArrayList("A1","A3","A4"));
    CSVIngester ingester = new CSVIngester(conf);
    List<Datum> data = ingester.getStream().drain();
    Datum datum = data.get(0);
    assertEquals(43, datum.metrics().getEntry(0), 0.0);
    assertEquals(45, datum.metrics().getEntry(1), 0.0);
}