database-stream-processor
database-stream-processor copied to clipboard
Streaming and Incremental Computation Framework
> `daemonize` is Unmaintained | Details | | | ------------------- | ---------------------------------------------- | | Status | unmaintained | | Package | `daemonize` | | Version | `0.4.1` | | URL...
Move the HTTP server module into a separate crate.
Trait dbsp::trace::cursor::Cursor requires the client to use `key_valid()`, `step_key()`, `val_valid()`, `step_val()`, and so on. The Rust iterator interface is not supported. It works, but it isn't very Rusty and perhaps...
Trait `dbsp::trace::cursor::Cursor`'s `weight()` requires `&mut self`, but this does not make sense conceptually. See PR #286.
`distinct` is a no-op when it is connected to the output of `aggregate`, `rolling_aggregate` or any other operator that outputs collections with unit weights only. Implement a simple optimization that...
here are the worst offenders (stdev > 2) using 10 runs on the CI machine same invocation as the ci.bash script: | query | ('elapsed', 'mean') | ('elapsed', 'std') |...
`std::sync::Mutex` is relatively slow, we should use the `parking_lot` mutex instead.
DBSP should be to handle incremental joins that do not use just field equality efficiently - they are still bilinear operators. The current API based on indexes does not allow...
For example, the adapter interface looks a lot like https://docs.rs/tokio-tower/latest/tokio_tower/ and it would be neat to use https://docs.rs/tokio-console/latest/tokio_console/ via https://github.com/tokio-rs/tracing to see what is going on in the circuits.
[LDBC Benchmarks](https://ldbcouncil.org/benchmarks/overview/) are a great source of tests that really hone in on the things we need to benchmark: - LDBC Social Network Benchmark (LDBC-SNB) - The Social Network Benchmark's...