Method writeOutCurrentRow

src/Processors/Transforms/WindowTransform.cpp:1065–1099

}

void WindowTransform::writeOutCurrentRow()
{
    chassert(current_row < partition_end);
    chassert(current_row.block >= first_block_number);

    const auto & block = blockAt(current_row);
    for (size_t wi = 0; wi < workspaces.size(); ++wi)
    {
        auto & ws = workspaces[wi];

        if (ws.window_function_impl)
        {
            ws.window_function_impl->windowInsertResultInto(this, wi);
        }
        else
        {
            IColumn * result_column = block.output_columns[wi].get();
            const auto * a = ws.aggregate_function.get();
            auto * buf = ws.aggregate_function_state.data();
            // FIXME does it also allocate the result on the arena?
            // We'll have to pass it out with blocks then...

            if (ws.is_aggregate_function_state)
            {
                /// We should use insertMergeResultInto to insert result into ColumnAggregateFunction
                /// correctly if result contains AggregateFunction's states
                a->insertMergeResultInto(buf, *result_column, arena.get());
            }
            else
            {
                a->insertResultInto(buf, *result_column, arena.get());
            }
        }
    }
}

static void assertSameColumns(const Columns & left_all,
    const Columns & right_all)