Package | Description |
---|---|
org.apache.giraph.partition |
Package of partitioning related objects.
|
Modifier and Type | Method and Description |
---|---|
static PartitionExchange |
PartitionBalancer.updatePartitionOwners(List<PartitionOwner> partitionOwnerList,
WorkerInfo myWorkerInfo,
Collection<? extends PartitionOwner> masterSetPartitionOwners)
Helper function to update partition owners and determine which
partitions need to be sent from a specific worker.
|
PartitionExchange |
WorkerGraphPartitionerImpl.updatePartitionOwners(WorkerInfo myWorkerInfo,
Collection<? extends PartitionOwner> masterSetPartitionOwners) |
PartitionExchange |
WorkerGraphPartitioner.updatePartitionOwners(WorkerInfo myWorkerInfo,
Collection<? extends PartitionOwner> masterSetPartitionOwners)
Get the partitions owners and update locally.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.