Module batch

Source
Expand description

A handle to a batch of updates

Modules§

proto_fetch_batch_filter
Nested message and enum types in ProtoFetchBatchFilter.

Structs§

Batch
A handle to a batch of updates that has been written to blob storage but which has not yet been appended to a shard.
BatchBuilder
A builder for Batches that allows adding updates piece by piece and then finishing it.
BatchBuilderConfig
A snapshot of dynamic configs to make it easier to reason about an individual run of BatchBuilder.
BatchBuilderInternal 🔒
BatchParts 🔒
PartDeletes 🔒
ProtoBatch
ProtoFetchBatchFilter
ProtoFetchBatchFilterListen
ProtoLease
ProtoLeasedBatchPart
This is only to impl ExchangeData, and so used between processes running the same version of code. It’s not durably written down anywhere.
UntrimmableColumns 🔒
A list of (lowercase) column names that persist will always retain stats for, even if it means going over the stats budget.

Enums§

Added
Indicates what work was done in a call to BatchBuilder::add
WritingRuns 🔒

Constants§

BATCH_DELETE_ENABLED 🔒
BLOB_TARGET_SIZE 🔒
A target maximum size of blob payloads in bytes. If a logical “batch” is bigger than this, it will be broken up into smaller, independent pieces. This is best-effort, not a guarantee (though as of 2022-06-09, we happen to always respect it). This target size doesn’t apply for an individual update that exceeds it in size, but that scenario is almost certainly a mis-use of the system.
ENCODING_COMPRESSION_FORMAT 🔒
ENCODING_ENABLE_DICTIONARY 🔒
INLINE_WRITES_SINGLE_MAX_BYTES 🔒
INLINE_WRITES_TOTAL_MAX_BYTES 🔒
MAX_RUNS 🔒
MAX_RUN_LEN 🔒
STRUCTURED_KEY_LOWER_LEN 🔒

Functions§

diffs_sum 🔒
Returns the total sum of diffs or None if there were no updates.
validate_truncate_batch 🔒