Function test_csv_empty_file

datafusion/core/src/datasource/file_format/csv.rs:829–847

()

    /// (file is empty)
    #[tokio::test]
    async fn test_csv_empty_file() -> Result<()> {
        let ctx = SessionContext::new();
        ctx.register_csv(
            "empty",
            "tests/data/empty_0_byte.csv",
            CsvReadOptions::new().has_header(false),
        )
        .await?;

        let query = "select * from empty where random() > 0.5;";
        let query_result = ctx.sql(query).await?.collect().await?;

        assert_snapshot!(batches_to_string(&query_result),@r"
        ++
        ++
        ");

        Ok(())
    }

    /// Read a single empty csv file with header
    ///