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.


Variable Index

 o DUQueues
Data Update Queue Array for each Information Sources
 o dus
count how many data updates received.
 o Index
Use relation as index.

Constructor Index

 o DataUpdateReceiver(Relation[])
Construct DataUpdateReceiver for an array of Relations.

Method Index

 o getDataUpdate(int)
Get data update from this receiver.
 o putDataUpdate(String, String, int, String)
Put data update into this receiver.

Variables

 o DUQueues
 Queue DUQueues[]
Data Update Queue Array for each Information Sources

 o Index
 Relation Index[]
Use relation as index.

 o dus
 int dus
count how many data updates received.

Constructors

 o 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

Methods

 o 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"
 o 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