org.apache.giraph.graph

Class AddressesAndPartitionsWritable

java.lang.Object

org.apache.giraph.graph.AddressesAndPartitionsWritable

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class AddressesAndPartitionsWritable
extends Object
implements org.apache.hadoop.io.Writable

Helper class to write descriptions of master, workers and partition owners

Constructor Summary

Constructors

Constructor and Description
AddressesAndPartitionsWritable() Constructor for reflection
AddressesAndPartitionsWritable(MasterInfo masterInfo, List<WorkerInfo> workerInfos, Collection<PartitionOwner> partitionOwners) Constructor when we want to serialize object

Method Summary

Modifier and Type	Method and Description
MasterInfo	getMasterInfo() Get master information
Collection<PartitionOwner>	getPartitionOwners() Get partition owners
List<WorkerInfo>	getWorkerInfos() Get all workers
void	readFields(DataInput input)
void	write(DataOutput output)

Methods inherited from class java.lang.Object

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

Constructor Detail

AddressesAndPartitionsWritable

public AddressesAndPartitionsWritable(MasterInfo masterInfo,
                                      List<WorkerInfo> workerInfos,
                                      Collection<PartitionOwner> partitionOwners)

Constructor when we want to serialize object

Parameters:

masterInfo - Master information

workerInfos - List of all workers

partitionOwners - Collection of partitions

AddressesAndPartitionsWritable

public AddressesAndPartitionsWritable()

Constructor for reflection

Method Detail

getMasterInfo

public MasterInfo getMasterInfo()

Get master information

Returns:

Master information

getWorkerInfos

public List<WorkerInfo> getWorkerInfos()

Get all workers

Returns:

List of all workers

getPartitionOwners

public Collection<PartitionOwner> getPartitionOwners()

Get partition owners

Returns:

Collection of partition owners

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