The example does not run correctly.

[RuiSiJia]

let ctx = SessionContext::new();
ctx.runtime_env().register_object_store("hdfs", "", Arc::new(HadoopFileSystem));
let table_name = "line_item";
println!(
    "Register table {} with parquet file {}",
    table_name, hdfs_file_uri
);
ctx.register_parquet(table_name, &hdfs_file_uri, ParquetReadOptions::default()).await?;

let sql = "SELECT count(*) FROM line_item";
let result = ctx.sql(sql).await?.collect().await?;

The above code cannot be run. HadoopFileSystem maybe is not correct.

[yahoNanJing]

Thanks @RuiSiJia for reporting this issue. It's caused by the API change of SessionContext. I'll fixed.