EVEDemo.SWEEP
Class DataUpdateReceiver
java.lang.Object
|
+--EVEDemo.SWEEP.DataUpdateReceiver
- public class DataUpdateReceiver
- extends java.lang.Object
- implements java.io.Serializable
This classed is only used for Andreas do Data Update Performance Evaluation.
It will received data updates from the middle layer of Andreas code.
Then, it will put the data updates to the corresponding queue for each IS
object. Then, the SWEEP will get those updates.
- See Also:
- Serialized Form
Field Summary |
(package private) Queue[] |
DUQueues
Data Update Queue Array for each Information Sources |
(package private) int |
dus
count how many data updates received. |
(package private) Relation[] |
Index
Use relation as index. |
Method Summary |
UpdateData |
getDataUpdate(int ISIndex)
Get data update from this receiver. |
void |
putDataUpdate(java.lang.String ISName,
java.lang.String RelName,
int Count,
java.lang.String Value)
Put data update into this receiver. |
Methods inherited from class java.lang.Object |
,
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
registerNatives,
toString,
wait,
wait,
wait |
DUQueues
Queue[] DUQueues
- Data Update Queue Array for each Information Sources
Index
Relation[] Index
- Use relation as index.
dus
int dus
- count how many data updates received.
DataUpdateReceiver
public DataUpdateReceiver(Relation[] rels)
- Construct DataUpdateReceiver for an array of Relations.
The order of rels is same as the order of ISProcess. So, they have same
index number.
- Parameters:
rels
- An array of Relations
putDataUpdate
public void putDataUpdate(java.lang.String ISName,
java.lang.String RelName,
int Count,
java.lang.String Value)
- Put data update into this receiver.
- Parameters:
ISName
- Information Source Name, Indeed, we don't need that.RelName
- Relation NameCount
- Number of tuples, could be negativeValue
- String of the tuple, format like: "a|b|c"
getDataUpdate
public UpdateData getDataUpdate(int ISIndex)
- Get data update from this receiver.
- Parameters:
ISIndex
- index number of IS, start from 1.- Returns:
- Relation of the update.