Method writePrefix

src/DataStreams/CountingBlockOutputStream.cpp:67–82

}

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

    stream->writePrefix();

    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);
}

void CountingBlockOutputStream::writeSuffix()
{