org.apache.giraph.block_app.library

Class VertexSuppliers

java.lang.Object

org.apache.giraph.block_app.library.VertexSuppliers

public class VertexSuppliers
extends Object

SupplierFromVertex that extract common information from vertex itself.

Method Summary

Modifier and Type	Method and Description
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterable<Edge<I,E>>>	vertexEdgesSupplier() Supplier which extracts and returns edges object.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,I>	vertexIdSupplier() Supplier which extracts and returns vertex ID.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>>	vertexNeighborsSupplier() Supplier which extracts and returns Iterator over all neighbor IDs.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>>	vertexNeighborsSupplier(Predicate<I> toSupply) Supplier which extracts and returns Iterator over neighbor IDs that return true for given predicate.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>>	vertexNeighborsSupplierWithIndex(PairPredicate<PrimitiveRefs.IntRef,I> toSupply) Supplier which gives Iterator over neighbor IDs that return true for given predicate over (index, target) Note - iterator returns reused object, so you need to "use" them, before calling next() again.
static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,V>	vertexValueSupplier() Supplier which extracts and returns vertex value.

Methods inherited from class java.lang.Object

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

Method Detail

vertexIdSupplier

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,I> vertexIdSupplier()

Supplier which extracts and returns vertex ID. (note - do not modify the object, as it is not returning a copy)

vertexValueSupplier

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,V> vertexValueSupplier()

Supplier which extracts and returns vertex value. (note - doesn't create a copy of vertex value)

vertexEdgesSupplier

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterable<Edge<I,E>>> vertexEdgesSupplier()

Supplier which extracts and returns edges object. (note - doesn't create a copy of vertex value)

vertexNeighborsSupplier

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>> vertexNeighborsSupplier()

Supplier which extracts and returns Iterator over all neighbor IDs. Note - iterator returns reused object, so you need to "use" them, before calling next() again.

vertexNeighborsSupplier

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>> vertexNeighborsSupplier(Predicate<I> toSupply)

Supplier which extracts and returns Iterator over neighbor IDs that return true for given predicate. Note - iterator returns reused object, so you need to "use" them, before calling next() again.

vertexNeighborsSupplierWithIndex

public static <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> SupplierFromVertex<I,V,E,Iterator<I>> vertexNeighborsSupplierWithIndex(PairPredicate<PrimitiveRefs.IntRef,I> toSupply)

Supplier which gives Iterator over neighbor IDs that return true for given predicate over (index, target) Note - iterator returns reused object, so you need to "use" them, before calling next() again.