[This is preliminary documentation and is subject to change.]
the coordinator class for a text reader. No additional metadata is needed to describe a block, so this just uses DfsBlocks
directly as work items
Inheritance Hierarchy
Microsoft.Research.Naiad.Frameworks.WorkGeneratorMatchingCoordinatorUri, IPEndPoint, DfsBlock, DfsBlock, IPAddress
Microsoft.Research.Naiad.Frameworks.Storage.DfsDfsBaseCoordinatorDfsBlock
Microsoft.Research.Naiad.Frameworks.Storage.DfsDfsBlockCoordinatorDfsBlock
Microsoft.Research.Naiad.Frameworks.Storage.DfsDfsTextCoordinator
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#
public class DfsTextCoordinator : DfsBlockCoordinator<DfsBlock>
The DfsTextCoordinator type exposes the following members.
Constructors
| Name | Description | |
|---|---|---|
 | DfsTextCoordinator |
create a coordinator for reading Dfs files with fixed-length blocks, made of text records
|
Methods
| Name | Description | |
|---|---|---|
 | EnumerateFileWork |
called to convert an input file into a list of blocks
(Inherited from DfsBlockCoordinatorTItem.) |
| EnumerateWork |
given an input string of a file or directory, expand it into a set of files, and then expand each file
into a set of matches using the derived-class implementation of EnumerateFileWork
(Inherited from DfsBaseCoordinatorTWorkDescription.) |
| ExpandWorkItem |
Called when a work item is going to be sent to a worker. If usedMatchingQueue is true then dataNode
is the endpoint of the dataNode that matches the worker
(Inherited from DfsBlockCoordinatorTItem.) |
| MakeBaseMatches |
For a given file, map a sequence of locations to a sequence of "base" matches. The workStub
component of the match doesn't need any file-specific metadata filled in. The categories component of the
match is set to the locations of that block. The DfsBlock fields will
all be filled in after this sequence has been returned
(Overrides DfsBlockCoordinatorTItemMakeBaseMatches(HdfsFile, IEnumerableIPEndPoint).) |
| MapWorkerToQueue |
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
(Inherited from DfsBaseCoordinatorTWorkDescription.) |
| NotifyQueueAddition |
called whenever a queue is added: keep our index of addresses up to date
(Inherited from DfsBaseCoordinatorTWorkDescription.) |
| NotifyQueueRemoval |
called whenever a queue is removed: keep our index of addresses up to date
(Inherited from DfsBaseCoordinatorTWorkDescription.) |
Fields
| Name | Description | |
|---|---|---|
 | client |
The client for doing basic DFS operations.
(Inherited from DfsBaseCoordinatorTWorkDescription.) |
See Also