Method run

filters/DividerFilter.cpp:177–254

PointViewSet DividerFilter::run(PointViewPtr inView)
{
    PointViewSet result;

    if (m_args->m_sizeMode == SizeMode::Capacity)
        m_args->m_size = ((inView->size() - 1) / m_args->m_size) + 1;

    std::vector<PointViewPtr> views;

    // If we are Partition or RoundRobin, we
    // make views of m_args->m_size. If we are Expression mode,
    // we will make new views once the expression passes the 'count'
    // number of times
    if (m_args->m_mode == Mode::Partition ||
        m_args->m_mode == Mode::RoundRobin)
    {
        for (point_count_t i = 0; i < m_args->m_size; ++i)
        {
            PointViewPtr v(inView->makeNew());
            views.push_back(v);
            result.insert(v);
        }
    }

    if (m_args->m_mode == Mode::Partition)
    {
        point_count_t limit = ((inView->size() - 1) / m_args->m_size) + 1;
        unsigned viewNum = 0;
        for (PointId i = 0; i < inView->size();)
        {
            views[viewNum]->appendPoint(*inView, i++);
            if (i % limit == 0)
                viewNum++;
        }
    }
    else if (m_args->m_mode == Mode::RoundRobin)
    {
        unsigned viewNum = 0;
        for (PointId i = 0; i < inView->size(); ++i)
        {
            views[viewNum]->appendPoint(*inView, i);
            viewNum++;
            if (viewNum == m_args->m_size)
                viewNum = 0;
        }
    }
    else if (m_args->m_mode == Mode::Expression)
    {
        // Go make our first view to insert points into. If none of the points
        // pass the expression, all of the points will be in a single view

        PointViewPtr firstView(inView->makeNew());
        views.push_back(firstView);
        result.insert(firstView);

        unsigned viewNum (0);

        for (PointRef point : *inView)