Method skipped_on_limit

datafusion/datasource/src/file_stream/work_source.rs:50–55

Return how many queued files should be counted as already processed when this stream stops early after hitting a global limit.

(&self)

    /// Return how many queued files should be counted as already processed
    /// when this stream stops early after hitting a global limit.
    pub(super) fn skipped_on_limit(&self) -> usize {
        match self {
            Self::Local(files) => files.len(),
            Self::Shared(_) => 0,
        }
    }
}

/// Shared source of work for sibling `FileStream`s