Module epochs 

EpochId → StoredEpoch.

Each row records one epoch’s metadata. The CF is populated by two independent indexer pipelines that emit partial records — one at epoch start, one at epoch end — combined by an associative merge operator that copies any field set in an operand into the accumulator.

Structs

EpochEnd

The end-of-epoch fields staged as a merge operand by end.

Constants

NAME

Functions

end

Build a partial StoredEpoch carrying the end-of-epoch fields. Indexer pipelines that observe an epoch’s final checkpoint stage this as a merge operand against the epoch’s key.

options

CF options: install the field-wise merge operator.

start

Build a partial StoredEpoch carrying the start-of-epoch fields. Indexer pipelines that observe an epoch’s first checkpoint stage this as a merge operand against the epoch’s key.

Type Aliases

Key

Value