John Mumm
John Mumm
Sometimes users might want to be able to control where a stage of the pipeline is executed. For example, if they are using a `local_key_by` to create local aggregations and...
`aloc` shows up in the code in relation to sources, sinks, and connectors. This meant "at least once connectors", but it currently is also used for components that are better...
Currently when the app developer implements a SinkEncoder, they have to call .done() on the Writer. This should be handled by Wallaroo, and they should simply write to the Writer...
Wallaroo applications are composed of distinct stages. A state computation stage corresponds to what is called a "step group", which is made up of all the steps holding keys related...
We should pass a reusable `Reader` into the `decode()` method of the decoder so that if the implementer wants to use one, they won't have to allocate a new one...
In the kind of use case we had in mind when initially proposing ephemeral windows, there's an SLA for computing an output for messages related to an ephemeral key within...
For ephemeral keys, we can significantly reduce the number of messages sent to the `KeyRegistry` by batching register_key/unregister_key calls at `StateRunner`. These batch calls can probably only occur on receipt...
Throughout the codebase, we use things called "Builders" to allow us to pass around immutable (i.e. `val`) data that can be used late in initialization to create mutable (i.e. `ref`)...
We have run into a number of bugs relating to the implicit OutgoingBoundary to DataChannel protocol. When these are caught, it is indirectly by end-to-end tests, which normally means we...