database-stream-processor icon indicating copy to clipboard operation
database-stream-processor copied to clipboard

Streaming and Incremental Computation Framework

Results 64 database-stream-processor issues
Sort by recently updated
recently updated
newest added

> `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...

enhancement

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') |...

enhancement

`std::sync::Mutex` is relatively slow, we should use the `parking_lot` mutex instead.

enhancement

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...

enhancement

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.

question

[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...

enhancement