Method close

src/Processors/Formats/Impl/ParallelDecodingBlockInputFormat.cpp:42–47

}

void ParallelDecodingBlockInputFormat::close()
{
    is_stopped = true;
    if (pool)
        pool->wait();
}

void ParallelDecodingBlockInputFormat::initializeIfNeeded()
{