Skip to main content

Pending Struct

Per-key in-flight bundle being assembled — one entry per pending join key. More...

Declaration

struct simaai::neat::graph::nodes::JoinBundle::Pending { ... }

Public Member Attributes Index

std::unordered_map< PortId, Sample >samples

Samples received per input port for this bundle. More...

std::int64_tlast_seen_ns = 0

Timestamp (ns) of the most recent sample on any port. More...

Description

Per-key in-flight bundle being assembled — one entry per pending join key.

Definition at line 81 of file JoinBundle.h.

Public Member Attributes

last_seen_ns

std::int64_t simaai::neat::graph::nodes::JoinBundle::Pending::last_seen_ns = 0

Timestamp (ns) of the most recent sample on any port.

Definition at line 84 of file JoinBundle.h.

84 std::int64_t last_seen_ns = 0;

samples

std::unordered_map<PortId, Sample> simaai::neat::graph::nodes::JoinBundle::Pending::samples

Samples received per input port for this bundle.

Definition at line 83 of file JoinBundle.h.

83 samples;

The documentation for this struct was generated from the following file:


Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.