src/sagemaker_xgboost_container/distributed.py
def synchronize(self, data):
        """Synchronize data with the cluster.

        This function allows every node to share state with every other node easily.
        This allows things like determining which nodes have data or not.

        :param data: data to send to the cluster
        :return: aggregated data from the all the nodes in the cluster
        """
        results = []
        for i in range(rabit.get_world_size()):
            if self.rank == i:
                logging.debug("Broadcasting data from self ({}) to others".format(self.rank))
                rabit.broadcast(data, i)
                results.append(data)
            else:
                logging.debug("Receiving data from {}".format(i))
                message = rabit.broadcast(None, i)
                results.append(message)
        return results
Synchronize data with the cluster.

        This function allows every node to share state with every other node easily.
        This allows things like determining which nodes have data or not.

        :param data: data to send to the cluster
        :return: aggregated data from the all the nodes in the cluster
        
Synchronize data with the cluster.
This function allows every node to share state with every other node easily.
This allows things like determining which nodes have data or not.
Synchronize data with the cluster . This function allows every node to share state with every other node easily . This allows things like determining which nodes have data or not .
def synchronize(self, data):
        results = []
        for i in range(rabit.get_world_size()):
            if self.rank == i:
                logging.debug("Broadcasting data from self ({}) to others".format(self.rank))
                rabit.broadcast(data, i)
                results.append(data)
            else:
                logging.debug("Receiving data from {}".format(i))
                message = rabit.broadcast(None, i)
                results.append(message)
        return results
def synchronize ( self , data ) : results = [ ] for i in range ( rabit . get_world_size ( ) ) : if self . rank == i : logging . debug ( "Broadcasting data from self ({}) to others" . format ( self . rank ) ) rabit . broadcast ( data , i ) results . append ( data ) else : logging . debug ( "Receiving data from {}" . format ( i ) ) message = rabit . broadcast ( None , i ) results . append ( message ) return results
Synchronize data with the cluster.
Synchronize data with the cluster .
"""Synchronize data with the cluster.

        This function allows every node to share state with every other node easily.
        This allows things like determining which nodes have data or not.

        :param data: data to send to the cluster
        :return: aggregated data from the all the nodes in the cluster
        """
aggregated data from the all the nodes in the cluster
aggregated data from the all the nodes in the cluster
self
data
data to send to the cluster
data to send to the cluster