DfsBaseCoordinatorTWorkDescriptionMapWorkerToQueue Method Naiad Help

[This is preliminary documentation and is subject to change.]

Called when a worker announces that it is ready for another work item, to find a work item on the worker's matching queue, if any. The worker may have multiple IP addresses, so it returns them all, and if any matches an address the datanode is listening on, then the worker is matched to that datanode

Namespace: Microsoft.Research.Naiad.Frameworks.Storage.Dfs
Assembly: Microsoft.Research.Naiad.Storage (in Microsoft.Research.Naiad.Storage.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
Copy
protected override MatchingCoordinatorTInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescriptionMatchQueue MapWorkerToQueue(
	IPAddress[] workerAddresses,
	ref IPEndPoint matchingDataNode
)

Parameters

workerAddresses
Type: System.NetIPAddress
the IP addresses of the worker's network interfaces
matchingDataNode
Type: System.NetIPEndPoint
the datanode endpoint of a matching queue, if any

Return Value

Type: MatchingCoordinatorTInput, TCategory, TWorkStub, TWorkDescription, TWorkerDescriptionMatchQueue
the matching queue, if there is one, otherwise null
See Also

Reference

DfsBaseCoordinatorTWorkDescription Class
Microsoft.Research.Naiad.Frameworks.Storage.Dfs Namespace