All Packages Class Hierarchy This Package Previous Next Index
Class SWEEP.DataUpdateReceiver
java.lang.Object
|
+----SWEEP.DataUpdateReceiver
- public class DataUpdateReceiver
- extends Object
- implements 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.
-
DUQueues
- Data Update Queue Array for each Information Sources
-
dus
- count how many data updates received.
-
Index
- Use relation as index.
-
DataUpdateReceiver(Relation[])
- Construct DataUpdateReceiver for an array of Relations.
-
getDataUpdate(int)
- Get data update from this receiver.
-
putDataUpdate(String, String, int, String)
- Put data update into this receiver.
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 synchronized void putDataUpdate(String ISName,
String RelName,
int Count,
String Value)
- Put data update into this receiver.
- Parameters:
- ISName - Information Source Name, Indeed, we don't need that.
- RelName - Relation Name
- Count - Number of tuples, could be negative
- Value - String of the tuple, format like: "a|b|c"
getDataUpdate
public synchronized UpdateData getDataUpdate(int ISIndex)
- Get data update from this receiver.
- Parameters:
- ISIndex - index number of IS, start from 1.
- Returns:
- Relation of the update.
All Packages Class Hierarchy This Package Previous Next Index