timely

library0.30.0rscratesunverified

A low-latency data-parallel dataflow system for stream processing in Rust.

# Cargo.toml
[dependencies]
timely = "0.30.0"

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · TIMELY

timely

asyncrustv0.30.0

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

Map

✓ use timely::dataflow::operators::Map;

Create a simple dataflow that increments numbers.

use timely::dataflow::operators::Map; use timely::dataflow::InputHandle; fn main() { timely::execute_from_args(std::env::args(), |worker| { let mut input = InputHandle::new(); worker.dataflow::<u64, _, _>(|scope| { input.to_stream(scope) .map(|x| x + 1) .inspect(|x| println!("seen: {}", x)); }); input.send(1); input.advance_to(1); worker.step(); }).unwrap(); }

Debug

Known issues

gotchaRequires a timely dataflow runtime; not suitable for single-threaded use without worker configuration.

fix

Ensure you call `timely::execute_from_args` or similar to start the runtime.

affects: >=0.1.0

Upgrade

Version history

0.30.0latest on crates.io

Audit

Dependencies

No dependency data recorded yet.

Agent activity

38 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/TimelyDataflow/timely-dataflow ↗

homepagehttps://github.com/TimelyDataflow/timely-dataflow ↗

docshttps://docs.rs/timely/ ↗