panicked at 'index out of bounds: the len is 2 but the index is 2' at datafusion-6.0.0/src/datasource/file_format/parquet.rs:272:13
blogs.zip
toml
[dependencies]
datafusion = "6"
tokio = "1.0"
main:
#[tokio::main]
async fn main() -> datafusion::error::Result<()> {
// register the table
let mut ctx = ExecutionContext::new();
ctx.register_parquet("example", "tests/blogs.parquet").await?;
let df = ctx.sql("SELECT reply FROM example GROUP BY reply LIMIT 100").await?;
let record_batches = df.collect().await?;
println!("sdasd {:?}", record_batches);
Ok(())
}
```