com.bigdata.rdf.graph.impl.bd

Class TLScheduler2

java.lang.Object

com.bigdata.rdf.graph.impl.bd.TLScheduler2

All Implemented Interfaces:

IGASScheduler, IGASSchedulerImpl

public class TLScheduler2
extends Object
implements IGASSchedulerImpl

This scheduler uses thread-local buffers (LinkedHashSet) to track the distinct vertices scheduled by each execution thread. After the computation round, those per-thread segments of the frontier are combined into a single global, compact, and ordered frontier. To maximize the parallel activity, the per-thread frontiers are sorted using N threads (one per segment). Finally, the frontier segments are combined using a MergeSortIterator - this is a sequential step with a linear cost in the size of the frontier.

Author:

Bryan Thompson

Constructor Summary

Constructors

Constructor and Description
TLScheduler2(GASEngine gasEngine)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear() Reset all internal state (and get rid of any thread locals).
void	compactFrontier(IStaticFrontier frontier) Compact the schedule into the new frontier.
void	schedule(org.openrdf.model.Value v) Add the vertex to the schedule.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TLScheduler2

public TLScheduler2(GASEngine gasEngine)

Method Detail

schedule

public void schedule(org.openrdf.model.Value v)

Description copied from interface: IGASScheduler

Add the vertex to the schedule.

Specified by:

schedule in interface IGASScheduler

Parameters:

v - The vertex.

clear

public void clear()

Description copied from interface: IGASSchedulerImpl

Reset all internal state (and get rid of any thread locals).

Specified by:

clear in interface IGASSchedulerImpl

compactFrontier

public void compactFrontier(IStaticFrontier frontier)

Description copied from interface: IGASSchedulerImpl

Compact the schedule into the new frontier.

Specified by:

compactFrontier in interface IGASSchedulerImpl