You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@arrow.apache.org by GitBox <gi...@apache.org> on 2022/03/31 06:21:00 UTC
[GitHub] [arrow-datafusion] jiangzhx edited a comment on issue #2044: wrong result when operation parquet
jiangzhx edited a comment on issue #2044:
URL: https://github.com/apache/arrow-datafusion/issues/2044#issuecomment-1084142721
confused....
print_row_with_parquet testcase get right result
pickup_datetime:2009-01-04 02:52:00 +00:00
print_row_with_datafusion get wrong result
pickup_datetime:1970-01-15 05:57:17.520
```Rust
use datafusion::error::Result;
use datafusion::prelude::ExecutionContext;
use std::convert::TryFrom;
use std::fs::File;
use std::path::Path;
use parquet::file::reader::FileReader;
use parquet::file::serialized_reader::SerializedFileReader;
#[tokio::test]
async fn print_row_with_parquet() -> Result<()> {
let path = Path::new("yellow_taxi_sample.parquet");
let row_iter = SerializedFileReader::try_from(path).unwrap().into_iter();
for row in row_iter {
println!("{}", row);
}
Ok(())
}
#[tokio::test]
async fn grouped_counts() -> Result<()> {
let mut ctx = ExecutionContext::new();
ctx.register_parquet("taxi_sample", "yellow_taxi_sample.parquet")
.await?;
let df = ctx.sql("SELECT * from taxi_sample").await?;
df.show().await?;
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.
To unsubscribe, e-mail: github-unsubscribe@arrow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org