(self, inst2node_idx, node_map)
return rs
count sample number in internal nodes during training
count sample number in internal nodes during training
count sample number in internal nodes during training
def count_node_sample_num(self, inst2node_idx, node_map):
        """
        count sample number in internal nodes during training
        """
        count_func = functools.partial(self.sample_count_map_func, node_map=node_map)
        rs = inst2node_idx.applyPartitions(count_func).reduce(self.sample_count_reduce_func)
        return rs
def count_node_sample_num ( self , inst2node_idx , node_map ) : count_func = functools . partial ( self . sample_count_map_func , node_map = node_map ) rs = inst2node_idx . applyPartitions ( count_func ) . reduce ( self . sample_count_reduce_func ) return rs