comphead commented on issue #17263:
URL: https://github.com/apache/datafusion/issues/17263#issuecomment-3211136803
Local test
```
#[tokio::test]
async fn test_array_has() -> Result<()> {
let tmp_dir = TempDir::new()?;
let ctx = SessionContext::new();
let binding = tmp_dir.path().join("single_file.parquet");
let target_path = binding.to_str().unwrap();
let _ = ctx.sql(format!("COPY (select [[true, false], [false, true],
[false, true]] a, [false, true] b union all select [[null, null]], null) to
'{target_path}' stored as parquet").as_str()).await?.collect().await?;
//let _ = ctx.sql(format!("COPY (select [[true, false], [false, true]]
a, [false, true] b union all select [[true, false], [false, true]] a, [false,
true] b) to '{target_path}' stored as
parquet").as_str()).await?.collect().await?;
let _ = ctx.sql(format!("CREATE EXTERNAL TABLE array_has STORED AS
PARQUET location '{target_path}'").as_str()).await?.collect().await?;
let actual = ctx.sql("select array_has(a, b) from
array_has").await?.collect().await?;
println!("{:?}", actual);
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
