com.bigdata.rdf.graph

Interface IGASEngine

All Known Implementing Classes:

BigdataGASEngine, GASEngine, RAMGASEngine, SAILGASEngine

public interface IGASEngine

The interface used to submit an IGASProgram for evaluation.

Author:

Bryan Thompson

Method Summary

Methods

Modifier and Type	Method and Description
int	getNThreads() The parallelism for the SCATTER and GATHER phases.
boolean	getSortFrontier() Return true iff the frontier should be sorted.
<VS,ES,ST> IGASContext<VS,ES,ST>	newGASContext(IGraphAccessor graphAccessor, IGASProgram<VS,ES,ST> program) Obtain an execution context for the specified IGASProgram.
void	shutdown() Polite shutdown.
void	shutdownNow() Immediate shutdown.

Method Detail

newGASContext

<VS,ES,ST> IGASContext<VS,ES,ST> newGASContext(IGraphAccessor graphAccessor,
                                             IGASProgram<VS,ES,ST> program)

Obtain an execution context for the specified IGASProgram.

Type Parameters:

VS - The generic type for the per-vertex state. This is scoped to the computation of the IGASProgram.

ES - The generic type for the per-edge state. This is scoped to the computation of the IGASProgram.

ST - The generic type for the SUM. This is often directly related to the generic type for the per-edge state, but that is not always true. The SUM type is scoped to the GATHER + SUM operation (NOT the computation).

Parameters:

graphAccessor - Indicates the graph to be processed.

program - The program to execute against that graph.

getSortFrontier

boolean getSortFrontier()

Return true iff the frontier should be sorted. Backends that benefit from an ordered frontier (e.g., to vector IOs) should return true. Backends that do not benefit from an ordered frontier (e.g., a backend based on hash collections in memory) should return false.

shutdown

void shutdown()

Polite shutdown.

shutdownNow

void shutdownNow()

Immediate shutdown.

getNThreads

int getNThreads()

The parallelism for the SCATTER and GATHER phases.