org.apache.giraph.partition

Class BasicPartitionOwner

java.lang.Object

org.apache.giraph.partition.BasicPartitionOwner

All Implemented Interfaces:

GiraphConfigurationSettable, ImmutableClassesGiraphConfigurable, PartitionOwner, org.apache.hadoop.io.Writable

public class BasicPartitionOwner
extends Object
implements PartitionOwner, ImmutableClassesGiraphConfigurable

Basic partition owner, can be subclassed for more complicated partition owner implementations.

Constructor Summary

Constructors

Constructor and Description
BasicPartitionOwner() Default constructor.
BasicPartitionOwner(int partitionId, WorkerInfo workerInfo) Constructor with partition id and worker info.
BasicPartitionOwner(int partitionId, WorkerInfo workerInfo, WorkerInfo previousWorkerInfo, String checkpointFilesPrefix) Constructor with partition id and worker info.

Method Summary

Modifier and Type	Method and Description
ImmutableClassesGiraphConfiguration	getConf() Return the configuration used by this object.
int	getPartitionId() Get the partition id that maps to the relevant Partition object
WorkerInfo	getPreviousWorkerInfo() Get the worker information that was previously responsible for the partition id.
WorkerInfo	getWorkerInfo() Get the worker information that is currently responsible for the partition id.
void	readFields(DataInput input)
void	readFieldsWithWorkerIds(DataInput input, Map<Integer,WorkerInfo> workerInfoMap) A match for writeWithWorkerIds method - for WorkerInfos it will read just task ids from input and then find the matching WorkerInfo in the provided map and set it
void	setConf(ImmutableClassesGiraphConfiguration conf) Set the configuration to be used by this object.
void	setPreviousWorkerInfo(WorkerInfo workerInfo) Set the previous worker info.
void	setWorkerInfo(WorkerInfo workerInfo) Set the current worker info.
String	toString()
void	write(DataOutput output)
void	writeWithWorkerIds(DataOutput output) Write to the output, but don't serialize the whole WorkerInfo, instead use just the task id

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicPartitionOwner

public BasicPartitionOwner()

Default constructor.

BasicPartitionOwner

public BasicPartitionOwner(int partitionId,
                           WorkerInfo workerInfo)

Constructor with partition id and worker info.

Parameters:

partitionId - Partition id of this partition.

workerInfo - Owner of the partition.

BasicPartitionOwner

public BasicPartitionOwner(int partitionId,
                           WorkerInfo workerInfo,
                           WorkerInfo previousWorkerInfo,
                           String checkpointFilesPrefix)

Constructor with partition id and worker info.

Parameters:

partitionId - Partition id of this partition.

workerInfo - Owner of the partition.

previousWorkerInfo - Previous owner of this partition.

checkpointFilesPrefix - Prefix of the checkpoint files.

Method Detail

getPartitionId

public int getPartitionId()

Description copied from interface: PartitionOwner

Get the partition id that maps to the relevant Partition object

Specified by:

getPartitionId in interface PartitionOwner

Returns:

Partition id

getWorkerInfo

public WorkerInfo getWorkerInfo()

Description copied from interface: PartitionOwner

Get the worker information that is currently responsible for the partition id.

Specified by:

getWorkerInfo in interface PartitionOwner

Returns:

Owning worker information.

setWorkerInfo

public void setWorkerInfo(WorkerInfo workerInfo)

Description copied from interface: PartitionOwner

Set the current worker info.

Specified by:

setWorkerInfo in interface PartitionOwner

Parameters:

workerInfo - Worker info responsible for partition

getPreviousWorkerInfo

public WorkerInfo getPreviousWorkerInfo()

Description copied from interface: PartitionOwner

Get the worker information that was previously responsible for the partition id.

Specified by:

getPreviousWorkerInfo in interface PartitionOwner

Returns:

Owning worker information or null if no previous worker info.

setPreviousWorkerInfo

public void setPreviousWorkerInfo(WorkerInfo workerInfo)

Description copied from interface: PartitionOwner

Set the previous worker info.

Specified by:

setPreviousWorkerInfo in interface PartitionOwner

Parameters:

workerInfo - Worker info that was previously responsible for the partition.

writeWithWorkerIds

public void writeWithWorkerIds(DataOutput output)
                        throws IOException

Description copied from interface: PartitionOwner

Write to the output, but don't serialize the whole WorkerInfo, instead use just the task id

Specified by:

writeWithWorkerIds in interface PartitionOwner

Parameters:

output - Output to write to

Throws:

IOException

readFieldsWithWorkerIds

public void readFieldsWithWorkerIds(DataInput input,
                                    Map<Integer,WorkerInfo> workerInfoMap)
                             throws IOException

Description copied from interface: PartitionOwner

A match for writeWithWorkerIds method - for WorkerInfos it will read just task ids from input and then find the matching WorkerInfo in the provided map and set it

Specified by:

readFieldsWithWorkerIds in interface PartitionOwner

Parameters:

input - Input to read from

workerInfoMap - Map from task id to WorkerInfo

Throws:

IOException

readFields

public void readFields(DataInput input)
                throws IOException

Specified by:

readFields in interface 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

Throws:

IOException

getConf

public ImmutableClassesGiraphConfiguration getConf()

Description copied from interface: ImmutableClassesGiraphConfigurable

Return the configuration used by this object.

Specified by:

getConf in interface ImmutableClassesGiraphConfigurable

Returns:

Set configuration

setConf

public void setConf(ImmutableClassesGiraphConfiguration conf)

Description copied from interface: GiraphConfigurationSettable

Set the configuration to be used by this object.

Specified by:

setConf in interface GiraphConfigurationSettable

Parameters:

conf - Set configuration

toString

public String toString()

Overrides:

toString in class Object