[[arrow::export]]
| 57 | |
| 58 | // [[arrow::export]] |
| 59 | std::shared_ptr<arrow::RecordBatch> ipc___ReadRecordBatch__Message__Schema( |
| 60 | const std::unique_ptr<arrow::ipc::Message>& message, |
| 61 | const std::shared_ptr<arrow::Schema>& schema) { |
| 62 | // TODO: perhaps this should come from the R side |
| 63 | arrow::ipc::DictionaryMemo memo; |
| 64 | auto batch = ValueOrStop(arrow::ipc::ReadRecordBatch( |
| 65 | *message, schema, &memo, arrow::ipc::IpcReadOptions::Defaults())); |
| 66 | return batch; |
| 67 | } |
| 68 | |
| 69 | // [[arrow::export]] |
| 70 | std::shared_ptr<arrow::Schema> ipc___ReadSchema_InputStream( |
no test coverage detected