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