Package | Description |
---|---|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
org.apache.giraph.edge |
Package of Vertex implementations.
|
org.apache.giraph.edge.primitives |
Package of edge stores specialized for certain type of vertex ids.
|
org.apache.giraph.factories |
Package of factories for creating types, for example the user's graph types.
|
org.apache.giraph.graph |
Package of all the graph related objects, built on the
org.apache.bsp package.
|
org.apache.giraph.jython |
Jython integration.
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
Modifier and Type | Field and Description |
---|---|
static ClassConfOption<OutEdges> |
GiraphConstants.INPUT_VERTEX_EDGES_CLASS
Vertex edges class to be used during edge input only - optional
|
protected Class<? extends OutEdges<I,E>> |
GiraphClasses.inputOutEdgesClass
Input vertex edges class - cached for fast access
|
protected Class<? extends OutEdges<I,E>> |
GiraphClasses.outEdgesClass
Vertex edges class - cached for fast access
|
static ClassConfOption<OutEdges> |
GiraphConstants.VERTEX_EDGES_CLASS
Vertex edges class - optional
|
Modifier and Type | Method and Description |
---|---|
OutEdges<I,E> |
ImmutableClassesGiraphConfiguration.createAndInitializeInputOutEdges()
Create an input
OutEdges instance and
initialize it with the default capacity. |
OutEdges<I,E> |
ImmutableClassesGiraphConfiguration.createAndInitializeOutEdges()
Create a
OutEdges instance and initialize
it with the default capacity. |
OutEdges<I,E> |
ImmutableClassesGiraphConfiguration.createAndInitializeOutEdges(int capacity)
Create a
OutEdges instance and initialize
it with the given capacity (the number of edges that will be added). |
OutEdges<I,E> |
ImmutableClassesGiraphConfiguration.createAndInitializeOutEdges(Iterable<Edge<I,E>> edges)
Create a
OutEdges instance and initialize
it with the given iterable of edges. |
OutEdges<I,E> |
ImmutableClassesGiraphConfiguration.createInputOutEdges()
Create a user
OutEdges used during
edge-based input |
OutEdges<I,E> |
ImmutableClassesGiraphConfiguration.createOutEdges()
Create a user
OutEdges |
Modifier and Type | Method and Description |
---|---|
Class<? extends OutEdges<I,E>> |
GiraphClasses.getInputOutEdgesClass()
Get Vertex edges class used during edge-based input
|
Class<? extends OutEdges<I,E>> |
ImmutableClassesGiraphConfiguration.getInputOutEdgesClass()
Get the user's subclassed
OutEdges used for
input |
Class<? extends OutEdges<I,E>> |
GiraphClasses.getOutEdgesClass()
Get Vertex edges class
|
Class<? extends OutEdges> |
GiraphConfiguration.getOutEdgesClass()
Get the vertex edges class
|
Class<? extends OutEdges<I,E>> |
ImmutableClassesGiraphConfiguration.getOutEdgesClass() |
Modifier and Type | Method and Description |
---|---|
GiraphClasses |
GiraphClasses.setInputOutEdgesClass(Class<? extends OutEdges> inputOutEdgesClass)
Set OutEdges class used during edge-input (if different from the one
used for computation)
|
void |
GiraphConfiguration.setInputOutEdgesClass(Class<? extends OutEdges> inputOutEdgesClass)
Set the vertex edges class used during edge-based input (if different
from the one used during computation)
|
GiraphClasses |
GiraphClasses.setOutEdgesClass(Class<? extends OutEdges> outEdgesClass)
Set OutEdges class held
|
void |
GiraphConfiguration.setOutEdgesClass(Class<? extends OutEdges> outEdgesClass)
Set the vertex edges class
|
Modifier and Type | Interface and Description |
---|---|
interface |
MultiRandomAccessOutEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Interface for
OutEdges implementations that provide efficient
random access to the edges given the target vertex id. |
interface |
MutableOutEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Interface for
OutEdges implementations that have an optimized
mutable edge iterator. |
interface |
ReuseObjectsOutEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Empty interface to characterize
OutEdges implementations that
don't keep references to the Edge (or id and value) objects they are passed. |
interface |
StrictRandomAccessOutEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Interface for
OutEdges implementations that provide efficient
random access to the edges given the target vertex id. |
Modifier and Type | Class and Description |
---|---|
class |
ArrayListEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
|
class |
ByteArrayEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
OutEdges implementation backed by a byte array. |
class |
ConfigurableOutEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Common base class for
OutEdges implementations that require a
configuration. |
class |
HashMapEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
|
class |
HashMultimapEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
OutEdges implementation backed by an ArrayListMultimap . |
class |
IdAndNullArrayEdges<I extends org.apache.hadoop.io.WritableComparable>
Implementation of
OutEdges with IDs and null edge values having
their TypeOps. |
class |
IdAndValueArrayEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Implementation of
OutEdges with IDs and Edge values having their
TypeOps. |
class |
IntNullArrayEdges
Implementation of
OutEdges with int ids and null edge
values, backed by dynamic primitive array. |
class |
LongByteHashMapEdges
OutEdges implementation with long ids and byte edge values,
backed by a Long2ByteOpenHashMap . |
class |
LongDiffNullArrayEdges
Implementation of
OutEdges with long ids
and null edge values, backed by a dynamic primitive array. |
class |
LongDoubleArrayEdges
Implementation of
OutEdges with long ids and double edge
values, backed by dynamic primitive arrays. |
class |
LongDoubleHashMapEdges
OutEdges implementation with long ids and double edge values,
backed by a Long2DoubleOpenHashMap . |
class |
LongNullArrayEdges
Implementation of
OutEdges with long ids and null edge
values, backed by a dynamic primitive array. |
class |
LongNullHashSetEdges
OutEdges implementation with long ids and null edge values,
backed by a LongOpenHashSet . |
class |
MutableEdgesWrapper<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Helper class that wraps the current out-edges and inserts them into a new
data structure as they are iterated over.
|
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Integer,Map<K,OutEdges<I,E>>> |
AbstractEdgeStore.transientEdges
Map used to temporarily store incoming edges.
|
Modifier and Type | Method and Description |
---|---|
OutEdges<I,E> |
MutableEdgesWrapper.getNewEdges()
Get the new
OutEdges data structure. |
protected abstract OutEdges<I,E> |
AbstractEdgeStore.getPartitionEdges(Et entry)
Return the OutEdges for a given partition
|
protected OutEdges<I,E> |
SimpleEdgeStore.getPartitionEdges(Map.Entry<I,OutEdges<I,E>> entry) |
protected OutEdges<I,E> |
SimpleEdgeStore.getVertexOutEdges(VertexIdEdgeIterator<I,E> vertexIdEdgeIterator,
Map<I,OutEdges<I,E>> partitionEdgesIn) |
protected abstract OutEdges<I,E> |
AbstractEdgeStore.getVertexOutEdges(VertexIdEdgeIterator<I,E> vertexIdEdgeIterator,
Map<K,OutEdges<I,E>> partitionEdgesIn)
Get out-edges for a given vertex
|
OutEdges<I,E> |
MutableEdgesWrapper.unwrap()
Moves all the remaining edges to the new data structure, and returns it.
|
Modifier and Type | Method and Description |
---|---|
protected ConcurrentMap<I,OutEdges<I,E>> |
SimpleEdgeStore.getPartitionEdges(int partitionId) |
protected abstract Map<K,OutEdges<I,E>> |
AbstractEdgeStore.getPartitionEdges(int partitionId)
Get OutEdges for a given partition
|
protected Iterator<Map.Entry<I,OutEdges<I,E>>> |
SimpleEdgeStore.getPartitionEdgesIterator(Map<I,OutEdges<I,E>> partitionEdges) |
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> |
MutableEdgesWrapper.wrap(OutEdges<I,E> edges,
ImmutableClassesGiraphConfiguration<I,?,E> conf)
Factory method to create a new wrapper over the existing out-edges.
|
Modifier and Type | Method and Description |
---|---|
protected I |
SimpleEdgeStore.createVertexId(Map.Entry<I,OutEdges<I,E>> entry) |
protected OutEdges<I,E> |
SimpleEdgeStore.getPartitionEdges(Map.Entry<I,OutEdges<I,E>> entry) |
protected Iterator<Map.Entry<I,OutEdges<I,E>>> |
SimpleEdgeStore.getPartitionEdgesIterator(Map<I,OutEdges<I,E>> partitionEdges) |
protected abstract Iterator<Et> |
AbstractEdgeStore.getPartitionEdgesIterator(Map<K,OutEdges<I,E>> partitionEdges)
Get iterator for partition edges
|
protected I |
SimpleEdgeStore.getVertexId(Map.Entry<I,OutEdges<I,E>> entry,
I representativeVertexId) |
protected OutEdges<I,E> |
SimpleEdgeStore.getVertexOutEdges(VertexIdEdgeIterator<I,E> vertexIdEdgeIterator,
Map<I,OutEdges<I,E>> partitionEdgesIn) |
protected abstract OutEdges<I,E> |
AbstractEdgeStore.getVertexOutEdges(VertexIdEdgeIterator<I,E> vertexIdEdgeIterator,
Map<K,OutEdges<I,E>> partitionEdgesIn)
Get out-edges for a given vertex
|
Modifier and Type | Method and Description |
---|---|
protected OutEdges<org.apache.hadoop.io.IntWritable,E> |
IntEdgeStore.getPartitionEdges(it.unimi.dsi.fastutil.ints.Int2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.IntWritable,E>> entry) |
protected OutEdges<org.apache.hadoop.io.LongWritable,E> |
LongEdgeStore.getPartitionEdges(it.unimi.dsi.fastutil.longs.Long2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.LongWritable,E>> entry) |
protected OutEdges<org.apache.hadoop.io.IntWritable,E> |
IntEdgeStore.getVertexOutEdges(VertexIdEdgeIterator<org.apache.hadoop.io.IntWritable,E> vertexIdEdgeIterator,
Map<Integer,OutEdges<org.apache.hadoop.io.IntWritable,E>> partitionEdgesIn) |
protected OutEdges<org.apache.hadoop.io.LongWritable,E> |
LongEdgeStore.getVertexOutEdges(VertexIdEdgeIterator<org.apache.hadoop.io.LongWritable,E> vertexIdEdgeIterator,
Map<Long,OutEdges<org.apache.hadoop.io.LongWritable,E>> partitionEdgesIn) |
Modifier and Type | Method and Description |
---|---|
protected it.unimi.dsi.fastutil.ints.Int2ObjectMap<OutEdges<org.apache.hadoop.io.IntWritable,E>> |
IntEdgeStore.getPartitionEdges(int partitionId) |
protected it.unimi.dsi.fastutil.longs.Long2ObjectMap<OutEdges<org.apache.hadoop.io.LongWritable,E>> |
LongEdgeStore.getPartitionEdges(int partitionId) |
protected Iterator<it.unimi.dsi.fastutil.ints.Int2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.IntWritable,E>>> |
IntEdgeStore.getPartitionEdgesIterator(Map<Integer,OutEdges<org.apache.hadoop.io.IntWritable,E>> partitionEdges) |
protected Iterator<it.unimi.dsi.fastutil.longs.Long2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.LongWritable,E>>> |
LongEdgeStore.getPartitionEdgesIterator(Map<Long,OutEdges<org.apache.hadoop.io.LongWritable,E>> partitionEdges) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.io.IntWritable |
IntEdgeStore.createVertexId(it.unimi.dsi.fastutil.ints.Int2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.IntWritable,E>> entry) |
protected org.apache.hadoop.io.LongWritable |
LongEdgeStore.createVertexId(it.unimi.dsi.fastutil.longs.Long2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.LongWritable,E>> entry) |
protected OutEdges<org.apache.hadoop.io.IntWritable,E> |
IntEdgeStore.getPartitionEdges(it.unimi.dsi.fastutil.ints.Int2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.IntWritable,E>> entry) |
protected OutEdges<org.apache.hadoop.io.LongWritable,E> |
LongEdgeStore.getPartitionEdges(it.unimi.dsi.fastutil.longs.Long2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.LongWritable,E>> entry) |
protected Iterator<it.unimi.dsi.fastutil.ints.Int2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.IntWritable,E>>> |
IntEdgeStore.getPartitionEdgesIterator(Map<Integer,OutEdges<org.apache.hadoop.io.IntWritable,E>> partitionEdges) |
protected Iterator<it.unimi.dsi.fastutil.longs.Long2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.LongWritable,E>>> |
LongEdgeStore.getPartitionEdgesIterator(Map<Long,OutEdges<org.apache.hadoop.io.LongWritable,E>> partitionEdges) |
protected org.apache.hadoop.io.IntWritable |
IntEdgeStore.getVertexId(it.unimi.dsi.fastutil.ints.Int2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.IntWritable,E>> entry,
org.apache.hadoop.io.IntWritable representativeVertexId) |
protected org.apache.hadoop.io.LongWritable |
LongEdgeStore.getVertexId(it.unimi.dsi.fastutil.longs.Long2ObjectMap.Entry<OutEdges<org.apache.hadoop.io.LongWritable,E>> entry,
org.apache.hadoop.io.LongWritable representativeVertexId) |
protected OutEdges<org.apache.hadoop.io.IntWritable,E> |
IntEdgeStore.getVertexOutEdges(VertexIdEdgeIterator<org.apache.hadoop.io.IntWritable,E> vertexIdEdgeIterator,
Map<Integer,OutEdges<org.apache.hadoop.io.IntWritable,E>> partitionEdgesIn) |
protected OutEdges<org.apache.hadoop.io.LongWritable,E> |
LongEdgeStore.getVertexOutEdges(VertexIdEdgeIterator<org.apache.hadoop.io.LongWritable,E> vertexIdEdgeIterator,
Map<Long,OutEdges<org.apache.hadoop.io.LongWritable,E>> partitionEdgesIn) |
Modifier and Type | Method and Description |
---|---|
OutEdges<I,E> |
DefaultOutEdgesFactory.newInstance() |
OutEdges<I,E> |
DefaultInputOutEdgesFactory.newInstance() |
OutEdges<I,E> |
OutEdgesFactory.newInstance()
Creates a new
instance . |
Modifier and Type | Method and Description |
---|---|
void |
AbstractComputation.addVertexRequest(I id,
V value,
OutEdges<I,E> edges)
Sends a request to create a vertex that will be available during the
next superstep.
|
void |
Computation.addVertexRequest(I id,
V value,
OutEdges<I,E> edges)
Sends a request to create a vertex that will be available during the
next superstep.
|
Modifier and Type | Method and Description |
---|---|
void |
JythonComputation.addVertexRequest(Object id,
Object vertexValue,
OutEdges edges)
Sends a request to create a vertex that will be available during the
next superstep.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> |
EdgeIterables.initialize(OutEdges<I,E> edges,
Iterable<Edge<I,E>> edgesIterable)
Initialize edges data structure and add the edges from edgesIterable.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.