Method readImpl

src/DataStreams/TTLBlockInputStream.cpp:122–135

}

Block TTLBlockInputStream::readImpl()
{
    if (all_data_dropped)
        return {};

    auto block = children.at(0)->read();
    for (const auto & algorithm : algorithms)
        algorithm->execute(block);

    if (!block)
        return block;

    return reorderColumns(std::move(block), header);
}

void TTLBlockInputStream::readSuffixImpl()
{