Uses of Interface
com.bigdata.rdf.graph.IGASState

Packages that use IGASState

Package	Description
com.bigdata.rdf.graph	The GAS (Gather Apply Scatter) API was developed for PowerGraph (aka GraphLab 2.1).
com.bigdata.rdf.graph.analytics	This package provides implementations of various graph analytics using the GAS API.
com.bigdata.rdf.graph.impl	This is an implementation of the GAS API for the bigdata platform.
com.bigdata.rdf.graph.impl.bd

Uses of IGASState in com.bigdata.rdf.graph

Methods in com.bigdata.rdf.graph that return IGASState

Modifier and Type	Method and Description
IGASState<VS,ES,ST>	IGASContext.getGASState() The computation state.

Methods in com.bigdata.rdf.graph with parameters of type IGASState

Modifier and Type	Method and Description
VS	IGASProgram.apply(IGASState<VS,ES,ST> state, org.openrdf.model.Value u, ST sum) Apply the reduced aggregation computed by GATHER + SUM to the vertex.
abstract org.openrdf.model.Value	BinderBase.bind(org.openrdf.model.ValueFactory vf, IGASState<VS,ES,ST> state, org.openrdf.model.Value v) Subclasses can implement this method if they follow the old single bind paradigm.
List<org.openrdf.model.Value>	BinderBase.bind(org.openrdf.model.ValueFactory vf, IGASState<VS,ES,ST> state, org.openrdf.model.Value u, IVariable<?>[] outVars, IBindingSet bs) Call BinderBase.bind(ValueFactory, IGASState, Value).
List<org.openrdf.model.Value>	IBinder.bind(org.openrdf.model.ValueFactory vf, IGASState<VS,ES,ST> state, org.openrdf.model.Value u, IVariable<?>[] outVars, IBindingSet bs) New multi-binding strategy allows binders to bind multiple values to a given output variable (multiplying the number of solutions by the number of bindings).
ST	IGASProgram.gather(IGASState<VS,ES,ST> state, org.openrdf.model.Value u, org.openrdf.model.Statement e) GATHER is a map/reduce over the edges of the vertex.
void	IGASProgram.initVertex(IGASContext<VS,ES,ST> ctx, IGASState<VS,ES,ST> state, org.openrdf.model.Value u) Callback to initialize the state for each vertex in the initial frontier before the first iteration.
boolean	IGASProgram.isChanged(IGASState<VS,ES,ST> state, org.openrdf.model.Value u) Return true iff the vertex should run its SCATTER phase.
void	IGASProgram.scatter(IGASState<VS,ES,ST> state, IGASScheduler sch, org.openrdf.model.Value u, org.openrdf.model.Statement e)
ST	IGASProgram.sum(IGASState<VS,ES,ST> state, ST left, ST right) SUM is a pair-wise reduction that is applied during the GATHER.
void	IReducer.visit(IGASState<VS,ES,ST> state, org.openrdf.model.Value u) Method is invoked for each result and is responsible for combining the results in whatever manner is meaningful for the procedure.

Uses of IGASState in com.bigdata.rdf.graph.analytics

Methods in com.bigdata.rdf.graph.analytics with parameters of type IGASState

Modifier and Type	Method and Description
BFS.VS	BFS.apply(IGASState<BFS.VS,BFS.ES,Void> state, org.openrdf.model.Value u, Void sum) NOP
CC.VS	CC.apply(IGASState<CC.VS,CC.ES,org.openrdf.model.Value> state, org.openrdf.model.Value u, org.openrdf.model.Value sum) Apply the reduced aggregation computed by GATHER + SUM to the vertex.
PR.VS	PR.apply(IGASState<PR.VS,PR.ES,Double> state, org.openrdf.model.Value u, Double sum) Apply the reduced aggregation computed by GATHER + SUM to the vertex.
SSSP.VS	SSSP.apply(IGASState<SSSP.VS,SSSP.ES,Integer> state, org.openrdf.model.Value u, Integer sum) NOP.
Void	BFS.gather(IGASState<BFS.VS,BFS.ES,Void> state, org.openrdf.model.Value u, org.openrdf.model.Statement e) Not used.
org.openrdf.model.Value	CC.gather(IGASState<CC.VS,CC.ES,org.openrdf.model.Value> state, org.openrdf.model.Value u, org.openrdf.model.Statement e) GATHER is a map/reduce over the edges of the vertex.
Double	PR.gather(IGASState<PR.VS,PR.ES,Double> state, org.openrdf.model.Value u, org.openrdf.model.Statement e) GATHER is a map/reduce over the edges of the vertex.
Integer	SSSP.gather(IGASState<SSSP.VS,SSSP.ES,Integer> state, org.openrdf.model.Value u, org.openrdf.model.Statement e) src.dist + edge_length (1)
Map<org.openrdf.model.Value,AtomicInteger>	CC.getConnectedComponents(IGASState<CC.VS,CC.ES,org.openrdf.model.Value> state) Returns a map containing the labels assigned to each connected component (which gives you a vertex in that connected component) and the #of vertices in each connected component.
void	BFS.initVertex(IGASContext<BFS.VS,BFS.ES,Void> ctx, IGASState<BFS.VS,BFS.ES,Void> state, org.openrdf.model.Value u) Not used.
void	PR.initVertex(IGASContext<PR.VS,PR.ES,Double> ctx, IGASState<PR.VS,PR.ES,Double> state, org.openrdf.model.Value u) Callback to initialize the state for each vertex in the initial frontier before the first iteration.
void	SSSP.initVertex(IGASContext<SSSP.VS,SSSP.ES,Integer> ctx, IGASState<SSSP.VS,SSSP.ES,Integer> state, org.openrdf.model.Value u) Set the SSSP.VS.dist() to ZERO (0).
boolean	BFS.isChanged(IGASState<BFS.VS,BFS.ES,Void> state, org.openrdf.model.Value u) Returns true.
boolean	CC.isChanged(IGASState<CC.VS,CC.ES,org.openrdf.model.Value> state, org.openrdf.model.Value u) Return true iff the vertex should run its SCATTER phase.
boolean	PR.isChanged(IGASState<PR.VS,PR.ES,Double> state, org.openrdf.model.Value u) Return true iff the vertex should run its SCATTER phase.
void	BFS.scatter(IGASState<BFS.VS,BFS.ES,Void> state, IGASScheduler sch, org.openrdf.model.Value u, org.openrdf.model.Statement e) The remote vertex is scheduled for activation unless it has already been visited.
void	CC.scatter(IGASState<CC.VS,CC.ES,org.openrdf.model.Value> state, IGASScheduler sch, org.openrdf.model.Value u, org.openrdf.model.Statement e) The remote vertex is scheduled for activation unless it has already been visited.
void	PR.scatter(IGASState<PR.VS,PR.ES,Double> state, IGASScheduler sch, org.openrdf.model.Value u, org.openrdf.model.Statement e) The remote vertex is scheduled for activation unless it has already been visited.
void	SSSP.scatter(IGASState<SSSP.VS,SSSP.ES,Integer> state, IGASScheduler sch, org.openrdf.model.Value u, org.openrdf.model.Statement e) The remote vertex is scheduled the weighted edge from this vertex to the remote vertex plus the weight on this vertex is less than the weight on the remote vertex.
Void	BFS.sum(IGASState<BFS.VS,BFS.ES,Void> state, Void left, Void right) Not used.
org.openrdf.model.Value	CC.sum(IGASState<CC.VS,CC.ES,org.openrdf.model.Value> state, org.openrdf.model.Value left, org.openrdf.model.Value right) MIN
Double	PR.sum(IGASState<PR.VS,PR.ES,Double> state, Double left, Double right) SUM
Integer	SSSP.sum(IGASState<SSSP.VS,SSSP.ES,Integer> state, Integer left, Integer right) UNUSED.
void	CC.ConnectedComponentsReducer.visit(IGASState<CC.VS,CC.ES,org.openrdf.model.Value> state, org.openrdf.model.Value u)
void	PR.PageRankReducer.visit(IGASState<PR.VS,PR.ES,Double> state, org.openrdf.model.Value u)

Uses of IGASState in com.bigdata.rdf.graph.impl

Classes in com.bigdata.rdf.graph.impl that implement IGASState

Modifier and Type	Class and Description
class	GASState<VS,ES,ST>

Methods in com.bigdata.rdf.graph.impl that return IGASState

Modifier and Type	Method and Description
IGASState<VS,ES,ST>	GASContext.getGASState()
<VS,ES,ST> IGASState<VS,ES,ST>	GASEngine.newGASState(IGraphAccessor graphAccessor, IGASProgram<VS,ES,ST> gasProgram)

Methods in com.bigdata.rdf.graph.impl with parameters of type IGASState

Modifier and Type	Method and Description
void	BaseGASProgram.initVertex(IGASContext<VS,ES,ST> ctx, IGASState<VS,ES,ST> state, org.openrdf.model.Value u) Callback to initialize the state for each vertex in the initial frontier before the first iteration.
boolean	BaseGASProgram.isChanged(IGASState<VS,ES,ST> state, org.openrdf.model.Value u) Return true iff the vertex should run its SCATTER phase.

Constructors in com.bigdata.rdf.graph.impl with parameters of type IGASState

Constructor and Description
GASContext(GASEngine gasEngine, IGraphAccessor graphAccessor, IGASState<VS,ES,ST> gasState, IGASProgram<VS,ES,ST> gasProgram)

Uses of IGASState in com.bigdata.rdf.graph.impl.bd

Classes in com.bigdata.rdf.graph.impl.bd that implement IGASState

Modifier and Type	Class and Description
class	BigdataGASState<VS,ES,ST>

Methods in com.bigdata.rdf.graph.impl.bd that return IGASState

Modifier and Type	Method and Description
<VS,ES,ST> IGASState<VS,ES,ST>	BigdataGASEngine.newGASState(IGraphAccessor graphAccessor, IGASProgram<VS,ES,ST> gasProgram)

Methods in com.bigdata.rdf.graph.impl.bd with parameters of type IGASState

Modifier and Type	Method and Description
PATHS.VS	PATHS.apply(IGASState<PATHS.VS,PATHS.ES,Void> state, org.openrdf.model.Value u, Void sum) NOP
Void	PATHS.gather(IGASState<PATHS.VS,PATHS.ES,Void> state, org.openrdf.model.Value u, org.openrdf.model.Statement e) Not used.
void	PATHS.initVertex(IGASContext<PATHS.VS,PATHS.ES,Void> ctx, IGASState<PATHS.VS,PATHS.ES,Void> state, org.openrdf.model.Value u) Not used.
boolean	PATHS.isChanged(IGASState<PATHS.VS,PATHS.ES,Void> state, org.openrdf.model.Value u) Returns true.
void	PATHS.scatter(IGASState<PATHS.VS,PATHS.ES,Void> state, IGASScheduler sch, org.openrdf.model.Value u, org.openrdf.model.Statement e) The remote vertex is scheduled for activation unless it has already been visited.
Void	PATHS.sum(IGASState<PATHS.VS,PATHS.ES,Void> state, Void left, Void right) Not used.
protected void	PATHS.visitPredecessors(IGASState<PATHS.VS,PATHS.ES,Void> gasState, org.openrdf.model.Value v, Set<org.openrdf.model.Value> retainSet)