hydroflow

hydroflow copied to clipboard

part 1

1

added semiring applications to algebra library.

chaeyeonlee07

MingweiSamuel

document `kvs_bench` example

3

We should provide a useful `README.md` for `kvs_bench`. Ideally we separate the functionality of the KVS from running the benchmark. Then document ~~(a) how to deploy the KVS for normal...

jhellerstein

Fix #1175

MingweiSamuel

feat(hydroflow)!:Change current_tick_start to wall clock time

3

Addresses #1187. Wall-clock time isn't monotonic, but that's expected to be understood.

rohitkulshreshtha

Deprecate/refactor old stateful/replaying operators

1

- [ ] replace `join` with `state_join` which can use keyed datastructures from `state()` op #969, bypass #564 - [ ] remove `persist()` (or replace with `state()`), replace `[lattice_]reduce/fold` with...

MingweiSamuel

Properties/semantics/optimizations meta-issue (algebraic properties/lattices)

2

Time to figure out our semantics, for optimizations - Old flow-property propagation code #895 - Some "lattices" are not *really* lattices (#916) > SSIV and immutables and other things aren't...

MingweiSamuel

make edge references cause scheduling

3

as pointed out by @shadaj When state changes it should trigger (the state/sources that feed into) the operators that reference that state

MingweiSamuel

Pluggable clocks in Hydroflow

4

The ability to plug clock implementations in Hydroflow will benefit deterministic (unit) testing. The current implementation binds to `Instant::now()`. ### LWW Clock Source (former #1207) A hybrid-logical clock source that...

rohitkulshreshtha

design: `poll_futures` is non-ergonomic in that it drives ticks from the middle of a stream

3

a linear pipeline starting with `source_iter` should probably only run on the first tick. However if it has a `poll_futures` in it, it may run on subsequent ticks. This suggests...

jhellerstein