database-stream-processor
database-stream-processor copied to clipboard
vmware
Streaming and Incremental Computation Framework
For example, we have join and join_incremental, distinct and distinct_incremental, but aggregate and stream_aggregate.
``` let agg = if input.key_valid() && input.key() == input_delta.key() { aggregator.aggregate(&mut CursorGroup::new(&mut input, ())) } else { None }; ``` The spec of the aggregate function seems it to...
The Rust code does not implement the SQL query exactly, in particular the LAG part of the query is not implemented. Either the Rust or the SQL should be updated.
Additionally, we probably want to add tracing to the main `dbsp` library.
This will simplify integration with case-insensitive frontends like SQL. The only downside I can think of is that people won't be able to create streams whose names only differ in...
In particular, Fold has 3 methods, and inherits a fourth one from a Semigroup structure. An API with 4 methods would be more natural.
Currently we have a lot of "benchmarks" that aren't actually benchmarks, they're full fledged binaries. Currently we have them set up as benchmarks which forces us to add their dependencies...
### Is your feature request related to a problem? Please describe. This will help us preallocate the right amount of buffer space in some situations, see e.g., the TODO in...
Ran into the following error (`CyclicCircuit`) trying to build a circuit; I'm fairly certain this should work. Minimal reproducible example: ```rs use dbsp::Circuit; fn main() { let (_, _) =...
