org.apache.giraph.partition

Class BasicPartition<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>

Type Parameters:

I - Vertex index value

V - Vertex value

E - Edge value

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

Direct Known Subclasses:

ByteArrayPartition, SimplePartition

public abstract class BasicPartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements Partition<I,V,E>

Basic partition class for other partitions to extend. Holds partition id, configuration, progressable and partition context

Constructor Summary

Constructors

Constructor and Description
BasicPartition()

Method Summary

Modifier and Type	Method and Description
void	addPartitionVertices(VertexIterator<I,V,E> vertexIterator) Add vertices to a partition.
ImmutableClassesGiraphConfiguration<I,V,E>	getConf() Return the configuration used by this object.
int	getId() Get the partition id.
VertexValueCombiner<V>	getVertexValueCombiner()
void	initialize(int partitionId, org.apache.hadoop.util.Progressable progressable) Initialize the partition.
void	progress() Report progress.
void	readFields(DataInput input)
void	setConf(ImmutableClassesGiraphConfiguration<I,V,E> configuration) Set the configuration to be used by this object.
void	setId(int id) Set the partition id.
void	setProgressable(org.apache.hadoop.util.Progressable progressable) Set the context.
void	write(DataOutput output)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.giraph.partition.Partition

addPartition, getEdgeCount, getVertex, getVertexCount, putOrCombine, putVertex, removeVertex, saveVertex

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Constructor Detail

BasicPartition

public BasicPartition()

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>

Parameters:

partitionId - Partition id

progressable - Progressable to call progress

setConf

public void setConf(ImmutableClassesGiraphConfiguration<I,V,E> configuration)

Description copied from interface: GiraphConfigurationSettable

Set the configuration to be used by this object.

Specified by:

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

Parameters:

configuration - Set configuration

getConf

public ImmutableClassesGiraphConfiguration<I,V,E> getConf()

Description copied from interface: ImmutableClassesGiraphConfigurable

Return the configuration used by this object.

Specified by:

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

Returns:

Set configuration

getId

public int getId()

Description copied from interface: Partition

Get the partition id.

Specified by:

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

Returns:

Id of this partition.

setId

public void setId(int id)

Description copied from interface: Partition

Set the partition id.

Specified by:

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

Parameters:

id - Id of this partition

progress

public void progress()

Description copied from interface: Partition

Report progress.

Specified by:

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

setProgressable

public void setProgressable(org.apache.hadoop.util.Progressable progressable)

Description copied from interface: Partition

Set the context.

Specified by:

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

Parameters:

progressable - Progressable

getVertexValueCombiner

public VertexValueCombiner<V> getVertexValueCombiner()

addPartitionVertices

public void addPartitionVertices(VertexIterator<I,V,E> vertexIterator)

Description copied from interface: Partition

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

Specified by:

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

Parameters:

vertexIterator - Vertices to add

write

public void write(DataOutput output)
           throws IOException

Specified by:

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

Throws:

IOException

readFields

public void readFields(DataInput input)
                throws IOException

Specified by:

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

Throws:

IOException