| 45 | using RecordBatchReader = ::arrow::RecordBatchReader; |
| 46 | |
| 47 | struct ReadStats { |
| 48 | /// Number of IPC messages read. |
| 49 | int64_t num_messages = 0; |
| 50 | /// Number of record batches read. |
| 51 | int64_t num_record_batches = 0; |
| 52 | /// Number of dictionary batches read. |
| 53 | /// |
| 54 | /// Note: num_dictionary_batches >= num_dictionary_deltas + num_replaced_dictionaries |
| 55 | int64_t num_dictionary_batches = 0; |
| 56 | |
| 57 | /// Number of dictionary deltas read. |
| 58 | int64_t num_dictionary_deltas = 0; |
| 59 | /// Number of replaced dictionaries (i.e. where a dictionary batch replaces |
| 60 | /// an existing dictionary with an unrelated new dictionary). |
| 61 | int64_t num_replaced_dictionaries = 0; |
| 62 | |
| 63 | /// The original endianness of the schema in the IPC file or stream. |
| 64 | /// This is not reflected in the schema returned by the RecordBatchReader |
| 65 | /// unless IpcReadOptions.ensure_native_endian is set to false. |
| 66 | Endianness original_endianness = Endianness::Native; |
| 67 | }; |
| 68 | |
| 69 | /// \brief Synchronous batch stream reader that reads from io::InputStream |
| 70 | /// |
no outgoing calls