DistNodeDataLoader(g, nids, graph_sampler, device=None, **kwargs)[source]¶
Sampled graph data loader over nodes for distributed graph storage.
It wraps an iterable over a set of nodes, generating the list of message flow graphs (MFGs) as computation dependency of the said minibatch, on a distributed graph.
All the arguments have the same meaning as the single-machine counterpart
dgl.dataloading.DataLoaderexcept the first argument
gwhich must be a
g (DistGraph) – The distributed graph.
graph_sampler, device, kwargs (nids,) – See
__init__(g, nids, graph_sampler, device=None, **kwargs)[source]¶
Initialize self. See help(type(self)) for accurate signature.
__init__(g, nids, graph_sampler[, device])