File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -114,6 +114,7 @@ fn validate_arrow_stream_ptr_mut<'a>(
114114// ---- Arrow IPC helpers ----
115115
116116/// Deserializes an `Arc<ArrowSchema>` from Arrow IPC stream bytes (schema-only stream).
117+ #[ allow( clippy:: result_large_err) ]
117118fn ipc_bytes_to_schema (
118119 bytes : & [ u8 ] ,
119120) -> ZerobusResult < std:: sync:: Arc < databricks_zerobus_ingest_sdk:: ArrowSchema > > {
@@ -126,6 +127,7 @@ fn ipc_bytes_to_schema(
126127}
127128
128129/// Deserializes the first `RecordBatch` from Arrow IPC stream bytes.
130+ #[ allow( clippy:: result_large_err) ]
129131fn ipc_bytes_to_record_batch ( bytes : & [ u8 ] ) -> ZerobusResult < RecordBatch > {
130132 use std:: io:: Cursor ;
131133 let cursor = Cursor :: new ( bytes) ;
@@ -139,6 +141,7 @@ fn ipc_bytes_to_record_batch(bytes: &[u8]) -> ZerobusResult<RecordBatch> {
139141}
140142
141143/// Serializes a `RecordBatch` to Arrow IPC stream bytes (schema + one batch).
144+ #[ allow( clippy:: result_large_err) ]
142145fn record_batch_to_ipc_bytes ( batch : & RecordBatch ) -> ZerobusResult < Vec < u8 > > {
143146 let mut buf = Vec :: new ( ) ;
144147 let mut writer = StreamWriter :: try_new ( & mut buf, batch. schema ( ) . as_ref ( ) ) . map_err ( |e| {
You can’t perform that action at this time.
0 commit comments