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.
 
Constructor Summary
DataUpdateReceiver(Relation[] rels)
          Construct DataUpdateReceiver for an array of Relations.
 
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
 

Field Detail

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.
Constructor Detail

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
Method Detail

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 Name
Count - Number of tuples, could be negative
Value - 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.