You are viewing an old version of this page. View the current version.
Compare with Current
View Page History
Version 1
Next »
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]);
header.setParameterId(buffer[0]);
contentHandler.setTimeSeriesHeader(header);
contentHandler.setTime(contentHandler.getDefaultTimeZone(), "yyyyMMdd", buffer[1]);
contentHandler.setValue('.', buffer[2]);
contentHandler.applyCurrentFields();
}
}
}