com.bigdata.rdf.graph.impl.scheduler

Class CHMScheduler

java.lang.Object

com.bigdata.rdf.graph.impl.scheduler.CHMScheduler

All Implemented Interfaces:

IGASScheduler, IGASSchedulerImpl

public class CHMScheduler
extends Object
implements IGASSchedulerImpl

A simple scheduler based on a ConcurrentHashMap.

Author:

Bryan Thompson

Constructor Summary

Constructors

Constructor and Description
CHMScheduler(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

CHMScheduler

public CHMScheduler(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