KnmiCsvTimeSeriesParser.java

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