MCPcopy Create free account
hub / github.com/apache/datafusion / with_limit_between_files

Function with_limit_between_files

datafusion/datasource/src/file_stream/mod.rs:627–643  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

625
626 #[tokio::test]
627 async fn with_limit_between_files() -> Result<()> {
628 let batches = create_and_collect(Some(5)).await;
629 #[rustfmt::skip]
630 assert_batches_eq!(&[
631 "+---+",
632 "| i |",
633 "+---+",
634 "| 0 |",
635 "| 1 |",
636 "| 2 |",
637 "| 0 |",
638 "| 1 |",
639 "+---+",
640 ], &batches);
641
642 Ok(())
643 }
644
645 #[tokio::test]
646 async fn with_limit_at_middle_of_batch() -> Result<()> {

Callers

nothing calls this directly

Calls 1

create_and_collectFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…