shaclapi.multiprocessing.Xgoptional.OperatorStructures module#

Created on Jul 10, 2011 Implements the structures used by the ANAPSID Operators. @author: Maribel Acosta Deibe

class shaclapi.multiprocessing.Xgoptional.OperatorStructures.Record(tuple, probeTS, insertTS=None, flushTS=None)[source]#

Bases: object

Represents a structure that is inserted into the hash table. It is composed by a tuple, probeTS (timestamp when the tuple was probed) and insertTS (timestamp when the tuple was inserted in the table).

class shaclapi.multiprocessing.Xgoptional.OperatorStructures.RJTTail(record, rjtProbeTS)[source]#

Bases: object

Represents the tail of a RJT. It is composed by a list of records and rjtprobeTS (timestamp when the last tuple in the RJT was probed).

updateRecords(record)[source]#

setRJTProbeTS(rjtProbeTS)[source]#

class shaclapi.multiprocessing.Xgoptional.OperatorStructures.FileDescriptor(file, size, lastFlushTS)[source]#

Bases: object

Represents the description of a file, that contains a RJT in sec mem. It is composed by the name of the file, the associated resource, the current size (number of tuples), and the timestamp of the last RJTTail that have been flushed.

getSize()[source]#