MCPcopy Create free account
hub / github.com/apache/arrow / ReadStats

Class ReadStats

cpp/src/arrow/ipc/reader.h:47–67  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

45using RecordBatchReader = ::arrow::RecordBatchReader;
46
47struct 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///

Calls

no outgoing calls