-
Notifications
You must be signed in to change notification settings - Fork 0
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Fix tests #9
Fix tests #9
Conversation
} | ||
} | ||
let actual = execute(&mut ctx, sql).await; | ||
let expected = vec![vec![""]; 100]; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
cast string to Int32 is possible in arrow2, cast failure will result in NULL
https://github.com/jorgecarleitao/arrow2/blob/main/src/compute/cast/mod.rs#L129
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
cool, filed apache#1056
assert!(!arrays.is_empty()); | ||
let first = arrays[0]; | ||
assert!(arrays.iter().all(|x| x.len() == first.len())); | ||
assert!(arrays.iter().all(|x| x.data_type() == first.data_type())); | ||
|
||
let size = arrays.len(); | ||
|
||
let values = concat::concatenate(arrays)?; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
array_array
is to zip elements at the same index for each array into a FixedSizeArray, therefore not identical to concatenate
that chain all arrays end to end.
@@ -441,7 +441,7 @@ impl ExecutionPlan for CsvExec { | |||
}); | |||
|
|||
Ok(Box::pin(CsvStream::new( | |||
self.schema.clone(), | |||
self.projected_schema.clone(), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The cause for failed tests csv_query_window_with_empty_over
and csv_query_window_with_order_by
. due to wrong schema provided.
almost there! |
The only flaky test remains:
csv_query_window_with_partition_by
.