Skip to main content

publish_partials

laminar_core::aggregation::two_phase

Function publish_partials 

Source 
pub fn publish_partials(
    store: &CrossPartitionAggregateStore,
    partials: &[PartialAggregate],
) -> Result<(), TwoPhaseError>
Expand description

Publish partial aggregates to a CrossPartitionAggregateStore.

Each partial is serialized to JSON and published under its (group_key, partition_id).

ยงErrors

Returns TwoPhaseError::Serde if serialization fails.