Method count_numpy

include/core/solver.h:1070–1080

Count edges for each sample block. This function can be parallelized. */

    /** Count edges for each sample block. This function can be parallelized. */
    void count_numpy(size_t start, size_t end, int id) {
        auto &offsets = solver->pool_offsets[id + 1];
        auto array = solver->array->unchecked();
        for (size_t i = start; i < end; i++) {
            Index head_global_id = array(i, 0);
            Index tail_global_id = array(i, 1);
            int head_partition_id = solver->head_locations[head_global_id].first;
            int tail_partition_id = solver->tail_locations[tail_global_id].first;
            offsets[head_partition_id][tail_partition_id]++;
        }
    }

    /** Distribute edges to the sample pool. This function can be parallelized. */
    void distribute(size_t start, size_t end, int id) {