Skip to content

Commit cc8fed8

Browse files
authored
chore: Fix Arrow IPC deprecated function (#69)
1 parent e0ade0a commit cc8fed8

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

README.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ axum-streams = { version = "0.18", features=["json", "csv", "protobuf", "text"]
2828

2929
| axum | axum-streams |
3030
|------|--------------|
31+
| 0.8 | v0.20+ |
3132
| 0.7 | v0.11+ |
3233
| 0.6 | v0.9-v0.10 |
3334
| 0.5 | 0.7 |

src/arrow_format.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,11 @@ impl StreamingFormat<RecordBatch> for ArrowRecordBatchIpcStreamFormat {
4646
let mut writer = BytesMut::new().writer();
4747

4848
if let Some(prepend_schema) = prepend_schema {
49-
let encoded_message = ipc_data_gen.schema_to_bytes(&prepend_schema, write_options);
49+
let encoded_message = ipc_data_gen.schema_to_bytes_with_dictionary_tracker(
50+
&prepend_schema,
51+
dictionary_tracker,
52+
write_options,
53+
);
5054
write_message(&mut writer, encoded_message, write_options)?;
5155
}
5256

0 commit comments

Comments
 (0)