Struct ArrayShardAggResp 

pub struct ArrayShardAggResp {
    pub shard_id: u32,
    pub partials: Vec<ArrayAggPartial>,
    pub truncated_before_horizon: bool,
}

Gather response: shard returns partial aggregate(s) for merge.

Fields

shard_id: u32

partials: Vec<ArrayAggPartial>

One partial per group-by bucket (or one entry when group_by_dim < 0).

truncated_before_horizon: bool

True when system_as_of is below the oldest tile version on this shard and the shard produced zero rows as a result of that horizon.

Trait Implementations

impl Clone for ArrayShardAggResp

fn clone(&self) -> ArrayShardAggResp

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ArrayShardAggResp

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'__msgpack_de> FromMessagePack<'__msgpack_de> for ArrayShardAggResp

fn read<R: Read<'__msgpack_de>>(reader: &mut R) -> Result<Self, Error>

where Self: Sized,

Reads the MessagePack representation of this value from the provided reader.

impl ToMessagePack for ArrayShardAggResp

fn write<W: Write>(&self, writer: &mut W) -> Result<(), Error>

Writes the MessagePack representation of this value into the provided writer.