I
- Vertex idV
- Vertex valueE
- Edge valuepublic interface WorkerGraphPartitioner<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
PartitionOwner
objects from the master and provides the
mapping of vertex to PartitionOwner
. Also generates the partition
owner implementation.Modifier and Type | Method and Description |
---|---|
PartitionOwner |
createPartitionOwner()
Instantiate the
PartitionOwner implementation used to read the
master assignments. |
Collection<PartitionStats> |
finalizePartitionStats(Collection<PartitionStats> workerPartitionStats,
PartitionStore<I,V,E> partitionStore)
At the end of a superstep, workers have
PartitionStats generated
for each of their partitions. |
PartitionOwner |
getPartitionOwner(I vertexId)
Figure out the owner of a vertex
|
Collection<? extends PartitionOwner> |
getPartitionOwners()
Get a collection of the
PartitionOwner objects. |
PartitionExchange |
updatePartitionOwners(WorkerInfo myWorkerInfo,
Collection<? extends PartitionOwner> masterSetPartitionOwners)
Get the partitions owners and update locally.
|
PartitionOwner createPartitionOwner()
PartitionOwner
implementation used to read the
master assignments.PartitionOwner
objectPartitionOwner getPartitionOwner(I vertexId)
vertexId
- Vertex id to get the partition forCollection<PartitionStats> finalizePartitionStats(Collection<PartitionStats> workerPartitionStats, PartitionStore<I,V,E> partitionStore)
PartitionStats
generated
for each of their partitions. This method will allow the user to
modify or create their own PartitionStats
interfaces to send to
the master.workerPartitionStats
- Stats generated by the infrastructure during
the supersteppartitionStore
- Partition store for this worker
(could be used to provide more useful stat information)PartitionExchange updatePartitionOwners(WorkerInfo myWorkerInfo, Collection<? extends PartitionOwner> masterSetPartitionOwners)
myWorkerInfo
- Worker info.masterSetPartitionOwners
- Master set partition owners, received
prior to beginning the superstepCollection<? extends PartitionOwner> getPartitionOwners()
PartitionOwner
objects.Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.