Method writeSuffix

src/DataStreams/CountingBlockOutputStream.cpp:84–99

}

void CountingBlockOutputStream::writeSuffix()
{
    stopwatch.start();

    stream->writeSuffix();

    Progress local_progress(0, 0, 0, stopwatch.elapsedMilliseconds());
    progress.incrementPiecewiseAtomically(local_progress);

    /// Update the write duration to progress
    if (process_elem)
        process_elem->updateProgressOut(local_progress);

    if (progress_callback)
        progress_callback(local_progress);
}


}