org.apache.giraph.partition

Class SimplePartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.partition.BasicPartition<I,V,E>

org.apache.giraph.partition.SimplePartition<I,V,E>

Type Parameters:

I - Vertex id

V - Vertex data

E - Edge data

All Implemented Interfaces:

Iterable<Vertex<I,V,E>>, GiraphConfigurationSettable<I,V,E>, ImmutableClassesGiraphConfigurable<I,V,E>, Partition<I,V,E>, org.apache.hadoop.io.Writable

@ThreadSafe
public class SimplePartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends BasicPartition<I,V,E>

A simple map-based container that stores vertices. Vertex ids will map to exactly one partition.

Constructor Summary

Constructors

Constructor and Description
SimplePartition() Constructor for reflection.

Method Summary

Modifier and Type	Method and Description
void	addPartition(Partition<I,V,E> partition) Add a partition's vertices.
long	getEdgeCount() Get the number of edges in this partition.
Vertex<I,V,E>	getVertex(I vertexIndex) Get the vertex for this vertex index.
long	getVertexCount() Get the number of vertices in this partition
void	initialize(int partitionId, org.apache.hadoop.util.Progressable progressable) Initialize the partition.
Iterator<Vertex<I,V,E>>	iterator()
boolean	putOrCombine(Vertex<I,V,E> vertex) Put this vertex or combine it
Vertex<I,V,E>	putVertex(Vertex<I,V,E> vertex) Put a vertex into the Partition
void	readFields(DataInput input)
Vertex<I,V,E>	removeVertex(I vertexIndex) Remove a vertex from the Partition
void	saveVertex(Vertex<I,V,E> vertex) Save potentially modified vertex back to the partition.
String	toString()
void	write(DataOutput output)

Methods inherited from class org.apache.giraph.partition.BasicPartition

addPartitionVertices, getConf, getId, getVertexValueCombiner, progress, setConf, setId, setProgressable

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

SimplePartition

public SimplePartition()

Constructor for reflection.

Method Detail

initialize

public void initialize(int partitionId,
                       org.apache.hadoop.util.Progressable progressable)

Description copied from interface: Partition

Initialize the partition. Guaranteed to be called before used.

Specified by:

initialize in interface Partition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Overrides:

initialize in class BasicPartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Parameters:

partitionId - Partition id

progressable - Progressable to call progress

getVertex

public Vertex<I,V,E> getVertex(I vertexIndex)

Description copied from interface: Partition

Get the vertex for this vertex index.

Parameters:

vertexIndex - Vertex index to search for

Returns:

Vertex if it exists, null otherwise

putVertex

public Vertex<I,V,E> putVertex(Vertex<I,V,E> vertex)

Description copied from interface: Partition

Put a vertex into the Partition

Parameters:

vertex - Vertex to put in the Partition

Returns:

old vertex value (i.e. null if none existed prior)

removeVertex

public Vertex<I,V,E> removeVertex(I vertexIndex)

Description copied from interface: Partition

Remove a vertex from the Partition

Parameters:

vertexIndex - Vertex index to remove

Returns:

The removed vertex.

putOrCombine

public boolean putOrCombine(Vertex<I,V,E> vertex)

Description copied from interface: Partition

Put this vertex or combine it

Parameters:

vertex - Vertex to put or combine

Returns:

True if the vertex was put (hint to release object)

addPartition

public void addPartition(Partition<I,V,E> partition)

Description copied from interface: Partition

Add a partition's vertices. If a vertex to be added doesn't exist, add it. If the vertex already exists, use the VertexValueCombiner to combine them.

Parameters:

partition - Partition to add

getVertexCount

public long getVertexCount()

Description copied from interface: Partition

Get the number of vertices in this partition

Returns:

Number of vertices

getEdgeCount

public long getEdgeCount()

Description copied from interface: Partition

Get the number of edges in this partition.

Returns:

Number of edges.

saveVertex

public void saveVertex(Vertex<I,V,E> vertex)

Description copied from interface: Partition

Save potentially modified vertex back to the partition.

Parameters:

vertex - Vertex to save

toString

public String toString()

Overrides:

toString in class Object

readFields

public void readFields(DataInput input)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Overrides:

readFields in class BasicPartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Throws:

IOException

write

public void write(DataOutput output)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Overrides:

write in class BasicPartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

Throws:

IOException

iterator

public Iterator<Vertex<I,V,E>> iterator()