-
Notifications
You must be signed in to change notification settings - Fork 1.5k
Update arrow 48.0.0 #7854
New issue
Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? # to your account
Update arrow 48.0.0 #7854
Conversation
d9eaf33
to
f4a4985
Compare
f4a4985
to
30d3269
Compare
@@ -58,8 +58,10 @@ AggregateExec: mode=Final, gby=[], aggr=[COUNT(*)] | |||
------RepartitionExec: partitioning=RoundRobinBatch(4), input_partitions=1 | |||
--------JsonExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/core/tests/data/2.json]]}, projection=[a] | |||
|
|||
query error DataFusion error: Schema error: No field named mycol\. | |||
query ? |
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.
@@ -37,13 +37,6 @@ pub struct CsvWriterOptions { | |||
/// Compression to apply after ArrowWriter serializes RecordBatches. | |||
/// This compression is applied by DataFusion not the ArrowWriter itself. | |||
pub compression: CompressionTypeVariant, | |||
/// Indicates whether WriterBuilder.has_header() is set to true. |
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.
🎉
3a28d98
to
f16fa15
Compare
"rfc3339" => { | ||
let value_bool = value.parse() | ||
.map_err(|_| DataFusionError::Configuration(format!("Unable to parse {value} as bool as required for {option}!")))?; | ||
if value_bool{ | ||
builder.with_rfc3339() | ||
} else{ | ||
builder | ||
} | ||
}, |
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.
@@ -523,9 +523,9 @@ mod tests { | |||
|
|||
let csv_options = CsvWriterOptions::try_from((&config, &options))?; | |||
let builder = csv_options.writer_options; | |||
assert!(builder.header()); |
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.
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.
Thank you everyone
Which issue does this PR close?
Closes #.
Rationale for this change
What changes are included in this PR?
Are these changes tested?
Are there any user-facing changes?