Uses of Class
org.apache.giraph.worker.WorkerInfo

Packages that use WorkerInfo

Package	Description
org.apache.giraph.bsp	Package of generic bulk synchronous processing objects.
org.apache.giraph.comm	Package of communication related objects, IPC service.
org.apache.giraph.comm.aggregators	Package for classes which are used to handle aggregators.
org.apache.giraph.comm.netty	Package for netty implementations.
org.apache.giraph.graph	Package of all the graph related objects, built on the org.apache.bsp package.
org.apache.giraph.master	Package of all the master related things.
org.apache.giraph.master.input	Input related master classes
org.apache.giraph.partition	Package of partitioning related objects.
org.apache.giraph.worker	Package of all the worker related things

Uses of WorkerInfo in org.apache.giraph.bsp

Methods in org.apache.giraph.bsp that return WorkerInfo

Modifier and Type	Method and Description
WorkerInfo	CentralizedServiceWorker.getWorkerInfo() Get the worker information
protected WorkerInfo	BspService.getWorkerInfoById(int id) Returns worker info corresponding to specified worker id.

Methods in org.apache.giraph.bsp that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	CentralizedServiceMaster.checkWorkers() Check all the WorkerInfo objects to ensure that a minimum number of good workers exists out of the total that have reported.
List<WorkerInfo>	CentralizedService.getWorkerInfoList() Get list of workers

Methods in org.apache.giraph.bsp with parameters of type WorkerInfo

Modifier and Type	Method and Description
String	BspService.getPartitionExchangeWorkerPath(long attempt, long superstep, WorkerInfo workerInfo) Based on the superstep, worker info, and attempt, get the appropriate worker path for the exchange.
protected int	BspService.getWorkerId(WorkerInfo workerInfo) For every worker this method returns unique number between 0 and N, where N is the total number of workers.

Uses of WorkerInfo in org.apache.giraph.comm

Methods in org.apache.giraph.comm that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
protected Map<WorkerInfo,List<Integer>>	SendDataCache.getWorkerPartitions()
PairList<WorkerInfo,PairList<Integer,D>>	SendDataCache.removeAllData() Gets all the data and removes it from the cache.
PairList<WorkerInfo,PairList<Integer,VertexIdEdges<I,E>>>	SendEdgeCache.removeAllEdges() Gets all the edges and removes them from the cache.

Methods in org.apache.giraph.comm with parameters of type WorkerInfo

Modifier and Type	Method and Description
int	SendVertexIdDataCache.addData(WorkerInfo workerInfo, int partitionId, byte[] serializedId, int idPos, T data) This method is similar to the method above, but use a serialized id to replace original I type destVertexId.
int	SendVertexIdDataCache.addData(WorkerInfo workerInfo, int partitionId, I destVertexId, T data) Add data to the cache.
int	SendEdgeCache.addEdge(WorkerInfo workerInfo, int partitionId, I destVertexId, Edge<I,E> edge) Add an edge to the cache.
protected int	SendMessageCache.addMessage(WorkerInfo workerInfo, int partitionId, byte[] serializedId, int idSerializerPos, M message) Add a message to the cache with serialized ids.
int	SendMessageCache.addMessage(WorkerInfo workerInfo, int partitionId, I destVertexId, M message) Add a message to the cache.
PairList<Integer,D>	SendDataCache.removeWorkerData(WorkerInfo workerInfo) Gets the data for a worker and removes it from the cache.
PairList<Integer,VertexIdEdges<I,E>>	SendEdgeCache.removeWorkerEdges(WorkerInfo workerInfo) Gets the edges for a worker and removes it from the cache.
protected PairList<Integer,VertexIdMessages<I,M>>	SendMessageCache.removeWorkerMessages(WorkerInfo workerInfo) Gets the messages for a worker and removes it from the cache.
void	WorkerClientRequestProcessor.sendPartitionRequest(WorkerInfo workerInfo, Partition<I,V,E> partition) Send a partition request (no batching).

Uses of WorkerInfo in org.apache.giraph.comm.aggregators

Methods in org.apache.giraph.comm.aggregators that return WorkerInfo

Modifier and Type	Method and Description
static WorkerInfo	AggregatorUtils.getOwner(String aggregatorName, List<WorkerInfo> workers) Get owner of aggregator with selected name from the list of workers

Method parameters in org.apache.giraph.comm.aggregators with type arguments of type WorkerInfo

Modifier and Type	Method and Description
static WorkerInfo	AggregatorUtils.getOwner(String aggregatorName, List<WorkerInfo> workers) Get owner of aggregator with selected name from the list of workers

Uses of WorkerInfo in org.apache.giraph.comm.netty

Methods in org.apache.giraph.comm.netty with parameters of type WorkerInfo

Modifier and Type	Method and Description
void	NettyWorkerClientRequestProcessor.doRequest(WorkerInfo workerInfo, WritableRequest writableRequest) When doing the request, short circuit if it is local
void	NettyWorkerClientRequestProcessor.sendPartitionRequest(WorkerInfo workerInfo, Partition<I,V,E> partition)

Uses of WorkerInfo in org.apache.giraph.graph

Methods in org.apache.giraph.graph that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	AddressesAndPartitionsWritable.getWorkerInfos() Get all workers

Constructor parameters in org.apache.giraph.graph with type arguments of type WorkerInfo

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

Uses of WorkerInfo in org.apache.giraph.master

Methods in org.apache.giraph.master that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	BspServiceMaster.checkWorkers()
List<WorkerInfo>	BspServiceMaster.getWorkerInfoList()
List<WorkerInfo>	MasterCompute.getWorkerInfoList() Get list of workers

Uses of WorkerInfo in org.apache.giraph.master.input

Method parameters in org.apache.giraph.master.input with type arguments of type WorkerInfo

Modifier and Type	Method and Description
void	MasterInputSplitsHandler.initialize(MasterClient masterClient, List<WorkerInfo> workers) Initialize

Constructor parameters in org.apache.giraph.master.input with type arguments of type WorkerInfo

Constructor and Description
LocalityAwareInputSplitsMasterOrganizer(List<byte[]> serializedSplits, List<org.apache.hadoop.mapreduce.InputSplit> splits, List<WorkerInfo> workers) Constructor
MappingInputSplitsMasterOrganizer(List<byte[]> serializedSplits, List<WorkerInfo> workers) Constructor

Uses of WorkerInfo in org.apache.giraph.partition

Methods in org.apache.giraph.partition that return WorkerInfo

Modifier and Type	Method and Description
WorkerInfo	BasicPartitionOwner.getPreviousWorkerInfo()
WorkerInfo	PartitionOwner.getPreviousWorkerInfo() Get the worker information that was previously responsible for the partition id.
WorkerInfo	BasicPartitionOwner.getWorkerInfo()
WorkerInfo	PartitionOwner.getWorkerInfo() Get the worker information that is currently responsible for the partition id.

Methods in org.apache.giraph.partition that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<WorkerInfo>	PartitionExchange.getMyDependencyWorkerSet() Get the workers that I must wait for
Map<WorkerInfo,List<Integer>>	PartitionExchange.getSendWorkerPartitionMap() Get a mapping of worker to list of partition ids I need to send to.

Methods in org.apache.giraph.partition with parameters of type WorkerInfo

Modifier and Type	Method and Description
void	BasicPartitionOwner.setPreviousWorkerInfo(WorkerInfo workerInfo)
void	PartitionOwner.setPreviousWorkerInfo(WorkerInfo workerInfo) Set the previous worker info.
void	BasicPartitionOwner.setWorkerInfo(WorkerInfo workerInfo)
void	PartitionOwner.setWorkerInfo(WorkerInfo workerInfo) Set the current worker info.
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.

Method parameters in org.apache.giraph.partition with type arguments of type WorkerInfo

Modifier and Type	Method and Description
static Collection<PartitionOwner>	PartitionBalancer.balancePartitionsAcrossWorkers(org.apache.hadoop.conf.Configuration conf, Collection<PartitionOwner> partitionOwners, Collection<PartitionStats> allPartitionStats, Collection<WorkerInfo> availableWorkerInfos) Balance the partitions with an algorithm based on a value.
Collection<PartitionOwner>	MasterGraphPartitionerImpl.createInitialPartitionOwners(Collection<WorkerInfo> availableWorkerInfos, int maxWorkers)
Collection<PartitionOwner>	MasterGraphPartitioner.createInitialPartitionOwners(Collection<WorkerInfo> availableWorkerInfos, int maxWorkers) Set some initial partition owners for the graph.
Collection<PartitionOwner>	MasterGraphPartitionerImpl.generateChangedPartitionOwners(Collection<PartitionStats> allPartitionStatsList, Collection<WorkerInfo> availableWorkers, int maxWorkers, long superstep)
Collection<PartitionOwner>	MasterGraphPartitioner.generateChangedPartitionOwners(Collection<PartitionStats> allPartitionStatsList, Collection<WorkerInfo> availableWorkers, int maxWorkers, long superstep) After the worker stats have been merged to a single list, the master can use this information to send commands to the workers for any Partition changes.
void	BasicPartitionOwner.readFieldsWithWorkerIds(DataInput input, Map<Integer,WorkerInfo> workerInfoMap)
void	PartitionOwner.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

Constructors in org.apache.giraph.partition with parameters of type WorkerInfo

Constructor and Description
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.

Constructor parameters in org.apache.giraph.partition with type arguments of type WorkerInfo

Constructor and Description
PartitionExchange(Set<WorkerInfo> myDependencyWorkerSet, Map<WorkerInfo,List<Integer>> sendWorkerPartitionMap) Only constructor.
PartitionExchange(Set<WorkerInfo> myDependencyWorkerSet, Map<WorkerInfo,List<Integer>> sendWorkerPartitionMap) Only constructor.

Uses of WorkerInfo in org.apache.giraph.worker

Methods in org.apache.giraph.worker that return WorkerInfo

Modifier and Type	Method and Description
WorkerInfo	BspServiceWorker.getWorkerInfo()

Methods in org.apache.giraph.worker that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	BspServiceWorker.getWorkerInfoList()
List<WorkerInfo>	AllWorkersInfo.getWorkerList() List of WorkerInfos

Methods in org.apache.giraph.worker with parameters of type WorkerInfo

Modifier and Type	Method and Description
int	AllWorkersInfo.getWorkerIndex(WorkerInfo workerInfo) For every worker this method returns unique number between 0 and N, where N is the total number of workers.

Constructors in org.apache.giraph.worker with parameters of type WorkerInfo

Constructor and Description
AllWorkersInfo(List<WorkerInfo> workers, WorkerInfo myWorker) Constructor
WorkerInputSplitsHandler(WorkerInfo workerInfo, int masterTaskId, WorkerClient workerClient) Constructor

Constructor parameters in org.apache.giraph.worker with type arguments of type WorkerInfo

Constructor and Description
AllWorkersInfo(List<WorkerInfo> workers, WorkerInfo myWorker) Constructor