Module read

Common structs and utilities for reading data.

Modules

• compat
  Utilities to adapt readers with different schema.
• dedup
  Utilities to remove duplicate rows from a sorted batch.
• last_row
  Utilities to read the last row of each time series.
• merge
  Merge reader implementation.
• projection
  Utilities for projection.
• prune 🔒
• range 🔒
  Structs for partition ranges.
• scan_region 🔒
  Scans a region according to the scan request.
• scan_util 🔒
  Utilities for scanners.
• seq_scan 🔒
  Sequential scan.
• unordered_scan 🔒
  Unordered scanner.

Structs

• Batch
  Storage internal representation of a batch of rows for a primary key (time series).
• BatchBuilder
  Builder to build Batch.
• BatchChecker 🔒
  A struct to check the batch is monotonic.
• BatchColumn
  A column in a Batch.
• ScannerMetrics 🔒
  Local metrics for scanners.

Enums

• Source
  Async Batch reader and iterator wrapper.

Constants

• TIMESTAMP_KEY_LEN 🔒
  Len of timestamp in arrow row format.

Traits

• BatchReader
  Async batch reader.

Functions

• concat_arrays 🔒
  Helper function to concat arrays from iter.

Type Aliases

• BoxedBatchReader
  Pointer to BatchReader.
• BoxedBatchStream
  Pointer to a stream that yields Batch.