JoinEncodedWithMetaOptions Struct
Configuration for a JoinEncodedWithMeta stage executor. More...
Declaration
Included Headers
Public Member Attributes Index
| PortId | encoded_port = kInvalidPort |
|
Optional: explicitly mark which input port carries encoded data. More... | |
| std::unordered_map< PortId, std::string > | port_names |
|
Optional: PortId -> name map for bundle field names. More... | |
| std::string | encoded_name = "encoded" |
|
Fallback name when encoded detection is implicit. More... | |
| std::size_t | max_pending = 1024 |
|
Max number of pending keys to hold before eviction. More... | |
| bool | emit_partial = true |
|
Emit a bundle even if some meta inputs are missing. More... | |
Description
Configuration for a JoinEncodedWithMeta stage executor.
Customises which input port carries the encoded payload, naming for bundle fields, and pending-bookkeeping bounds for the join.
Definition at line 30 of file JoinEncodedWithMeta.h.
Public Member Attributes
emit_partial
|
Emit a bundle even if some meta inputs are missing.
Definition at line 40 of file JoinEncodedWithMeta.h.
encoded_name
|
Fallback name when encoded detection is implicit.
Definition at line 36 of file JoinEncodedWithMeta.h.
encoded_port
|
Optional: explicitly mark which input port carries encoded data.
Definition at line 32 of file JoinEncodedWithMeta.h.
max_pending
|
Max number of pending keys to hold before eviction.
Definition at line 38 of file JoinEncodedWithMeta.h.
port_names
|
Optional: PortId -> name map for bundle field names.
Definition at line 34 of file JoinEncodedWithMeta.h.
The documentation for this struct was generated from the following file:
Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.