shaclapi.multiprocessing.Xgjoin.Xgjoin module#

Created on Jul 10, 2011 Implements the Xgjoin operator. The intermediate results are represented as a queue. @author: Maribel Acosta Deibe

class shaclapi.multiprocessing.Xgjoin.Xgjoin.Xgjoin(vars, memory_size)[source]#

Bases: object

instantiate(d)[source]#

instantiateFilter(instantiated_vars, filter_str)[source]#

execute(left, right, out, processqueue=<multiprocessing.queues.Queue object>)[source]#

stage1(tuple, tuple_rjttable, other_rjttable)[source]#

stage2(signum, frame)[source]#

stage3()[source]#

probe(tuple, resource, rjttable)[source]#

probeFile(rjt1, filedescriptor2, resource, stage)[source]#

flushRJT()[source]#

getVictim(table)[source]#

getLargestRJTs(i)[source]#