Method run

src/modules/stats/coxph_improved.cpp:75–99

// ------------------------------------------------------------

AnyType split_transition::run(AnyType &args)
{
    double val = args[1].getAs<double>();
    int buff_size = args[2].getAs<int>();
    int num_splits = args[3].getAs<int>();
    if (num_splits == 1)
        return Null();

    MutableArrayHandle<double> state(NULL);
    if (args[0].isNull()) {
        state = allocateArray<double>(buff_size + 2);
        state[0] = 0;
        state[1] = num_splits;
    } else {
        state = args[0].getAs<MutableArrayHandle<double> >();
    }

    // The pre-allocated buffer has been filled up
    if (state[0] >= buff_size) {
        return state;
    }

    state[static_cast<int>(++state[0]) + 1] = val;
    return state;
}

// ------------------------------------------------------------