package nl.wldelft.fews.system.plugin.dataImport; import nl.wldelft.util.io.LineReader; import nl.wldelft.util.io.TextParser; import nl.wldelft.util.timeseries.DefaultTimeSeriesHeader; import nl.wldelft.util.timeseries.TimeSeriesContentHandler; public class KnmiCsvTimeSeriesParser implements TextParser<TimeSeriesContentHandler> { @Override public void parse(LineReader reader, String virtualFileName, TimeSeriesContentHandler contentHandler) throws Exception { DefaultTimeSeriesHeader header = new DefaultTimeSeriesHeader(); for (String[] buffer = new String[3]; reader.readLine(',', buffer) != -1;) { header.setLocationId(buffer[0]); contentHandler.setTimeSeriesHeader(header); contentHandler.setTime(contentHandler.getDefaultTimeZone(), "yyyyMMdd", buffer[1]); contentHandler.setValue('.', buffer[2]); contentHandler.applyCurrentFields(); } } }