dgl.contrib.sampling.dis_sampler.SamplerSender.send¶

SamplerSender.send(nodeflow, recv_id)[source]¶

Send sampled subgraph (NodeFlow) to remote trainer. Note that, the send() API is non-blocking and it returns immediately if the underlying message queue is not full.

Parameters:	nodeflow (NodeFlow) – sampled NodeFlow recv_id (int) – receiver’s ID