Expand description
Data part of a shard.
Structs§
- Data
Batch - Data part batches returns by
DataParts::read. - Data
Batch 🔒Range - Range of a data batch.
- Data
Buffer - Buffer for the value part (pk_index, ts, sequence, op_type, field columns) in a shard.
- Data
Buffer 🔒Reader - Data
Buffer 🔒Reader Builder - Data
Part 🔒Encoder - Data
Part Reader - Data
Parts - Data parts under a shard.
- Data
Parts Reader - Reader for all parts inside a
DataParts. - Data
Parts Reader Builder - Inner
Key 🔒 - Parquet
Part - Parquet-encoded
DataPart.
Enums§
- Data
Part - Format of immutable data part.
- Lazy
Field 🔒Vector - Lazy
Mutable 🔒Vector Builder
Constants§
- DATA_
INIT_ 🔒CAP - Initial capacity for the data buffer.
- PK_
INDEX_ 🔒COLUMN_ NAME
Functions§
- build_
row_ 🔒sort_ indices_ and_ columns - build_
rows_ 🔒to_ sort - drain_
data_ 🔒buffer_ to_ record_ batches - Converts
DataBufferto record batches, with rows sorted according to pk_weights.dedup: whether to true to remove the duplicated rows insideDataBuffer.replace_pk_index: whether to replace the pk_index values with corresponding pk weight. - memtable_
schema_ 🔒to_ encoded_ schema - pk_
index_ 🔒array - Gets
pk_indexarray from record batch. - search_
next_ 🔒pk_ range - Searches for next pk index, and it’s offset range in a sorted
UInt16Array. - timestamp_
array_ 🔒to_ i64_ slice