[Bprocessor-commit] model/src/net/sourceforge/bprocessor/model/sense/core History.java, NONE, 1.1
Status: Pre-Alpha
Brought to you by:
henryml
From: Michael L. <he...@us...> - 2010-08-31 13:48:10
|
Update of /cvsroot/bprocessor/model/src/net/sourceforge/bprocessor/model/sense/core In directory sfp-cvsdas-2.v30.ch3.sourceforge.com:/tmp/cvs-serv20256/src/net/sourceforge/bprocessor/model/sense/core Added Files: History.java Target.java package.html Sensor.java Provider.java Consumer.java Producer.java Measurement.java Log Message: --- NEW FILE: Producer.java --- package net.sourceforge.bprocessor.model.sense.core; import java.util.LinkedList; import java.util.List; public class Producer { private List<Consumer> consumers; public Producer() { consumers = new LinkedList<Consumer>(); } public void add(Consumer consumer) { consumers.add(consumer); } public void remove(Consumer consumer) { consumers.remove(consumer); } public void consume(Measurement value) { for (Consumer current : consumers) { current.consume(value); } } } --- NEW FILE: Measurement.java --- package net.sourceforge.bprocessor.model.sense.core; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date; public class Measurement { private long time; private String value; public Measurement() { } public Measurement(long time, String value) { this.time = time; this.value = value; } public void setTime(long value) { time = value; } public long getTime() { return time; } public void setValue(String string) { value = string; } public String getValue() { return value; } public String toString() { DateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm:ss"); String str = format.format(new Date(time)); return "(" + str + " | " + value + ")"; } } --- NEW FILE: History.java --- package net.sourceforge.bprocessor.model.sense.core; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; public abstract class History { public abstract List<Measurement> fetch(Target target, Sensor sensor, Date from); public abstract List<Measurement> fetch(Target target, Sensor sensor, Date from, Date to); public Map<Sensor, List<Measurement>> fetch(Target target, Date from) { Map<Sensor, List<Measurement>> result = new HashMap<Sensor, List<Measurement>>(); for (Sensor current : target.getSensors()) { result.put(current, fetch(target, current, from)); } return result; } public Map<Sensor, List<Measurement>> fetch(Target target, Date from, Date to) { Map<Sensor, List<Measurement>> result = new HashMap<Sensor, List<Measurement>>(); for (Sensor current : target.getSensors()) { result.put(current, fetch(target, current, from, to)); } return result; } } --- NEW FILE: Sensor.java --- package net.sourceforge.bprocessor.model.sense.core; public class Sensor { private String id; private String type; public Sensor() { } public Sensor(String id, String type) { this.id = id; this.type = type; } public void setId(String value) { id = value; } public String getId() { return id; } public void setType(String value) { type = value; } public String getType() { return type; } } --- NEW FILE: Target.java --- package net.sourceforge.bprocessor.model.sense.core; import java.util.LinkedList; import java.util.List; public class Target { private String id; List<Sensor> sensors; public Target() { } public Target(String id) { this.id = id; sensors = new LinkedList<Sensor>(); } public void setId(String value) { id = value; } public String getId() { return id; } public void setSensors(List<Sensor> value) { sensors = value; } public List<Sensor> getSensors() { return sensors; } } --- NEW FILE: package.html --- <body> Defines the package that contains the model </body> --- NEW FILE: Provider.java --- package net.sourceforge.bprocessor.model.sense.core; public class Provider { } --- NEW FILE: Consumer.java --- package net.sourceforge.bprocessor.model.sense.core; public abstract class Consumer { public abstract void consume(Measurement value); } |