juaby opened a new issue #311:
URL: https://github.com/apache/arrow-datafusion/issues/311
```
#[tokio::main]
async fn main() -> Result<()> {
// create local execution context
let mut ctx = ExecutionContext::new();
let testdata = datafusion::arrow::util::test_util::arrow_test_data();
// register csv file with the execution context
ctx.register_csv(
"aggregate_test_100",
&format!("{}/csv/aggregate_test_100.csv", testdata),
CsvReadOptions::new(),
)?;
ctx.register_csv(
"aggregate_test_200",
&format!("{}/csv/aggregate_test_100.csv", testdata),
CsvReadOptions::new(),
)?;
// execute the query
let df = ctx.sql(
"SELECT a1.c1, MIN(a1.c12), MAX(a1.c12) \
FROM aggregate_test_100 a1 left join aggregate_test_200 a2 on a1.c1
= a2.c1 \
WHERE a1.c11 > 0.1 AND a1.c11 < 0.9 \
GROUP BY a1.c1 order by a1.c1 limit 2",
)?;
let results = df.collect().await?;
// print the results
pretty::print_batches(&results)?;
Ok(())
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
