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

Function without_limit

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

Source from the content-addressed store, hash-verified

600
601 #[tokio::test]
602 async fn without_limit() -> Result<()> {
603 let batches = create_and_collect(None).await;
604
605 #[rustfmt::skip]
606 assert_batches_eq!(&[
607 "+---+",
608 "| i |",
609 "+---+",
610 "| 0 |",
611 "| 1 |",
612 "| 2 |",
613 "| 0 |",
614 "| 1 |",
615 "| 0 |",
616 "| 1 |",
617 "| 2 |",
618 "| 0 |",
619 "| 1 |",
620 "+---+",
621 ], &batches);
622
623 Ok(())
624 }
625
626 #[tokio::test]
627 async fn with_limit_between_files() -> 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…