{"id":65352,"library":"timely","title":"Timely Dataflow","description":"A low-latency data-parallel dataflow system for stream processing in Rust.","status":"active","version":"0.30.0","language":"rust","source_language":null,"source_url":"https://github.com/TimelyDataflow/timely-dataflow","tags":["dataflow","stream-processing","parallel","low-latency"],"install":[{"cmd":"# Cargo.toml\n[dependencies]\ntimely = \"0.30.0\"","lang":"toml","label":"Cargo.toml"},{"cmd":"cargo add timely","lang":"bash","label":"cargo add"}],"dependencies":[],"imports":[{"symbol":"Map","correct":"use timely::dataflow::operators::Map;"}],"quickstart":{"code":"use timely::dataflow::operators::Map;\nuse timely::dataflow::InputHandle;\n\nfn main() {\n    timely::execute_from_args(std::env::args(), |worker| {\n        let mut input = InputHandle::new();\n        worker.dataflow::<u64, _, _>(|scope| {\n            input.to_stream(scope)\n                .map(|x| x + 1)\n                .inspect(|x| println!(\"seen: {}\", x));\n        });\n        input.send(1);\n        input.advance_to(1);\n        worker.step();\n    }).unwrap();\n}","lang":"rust","description":"Create a simple dataflow that increments numbers."},"warnings":[{"fix":"Ensure you call `timely::execute_from_args` or similar to start the runtime.","message":"Requires a timely dataflow runtime; not suitable for single-threaded use without worker configuration.","severity":"gotcha","affected_versions":">=0.1.0"}],"env_vars":null,"search_vec":"'data':8 'data-parallel':7 'dataflow':2,10,17 'latenc':6,24 'low':5,23 'low-lat':4,22 'parallel':9,21 'process':14,20 'rust':16 'stream':13,19 'stream-process':18 'system':11 'time':1","created_at":"2026-06-17T17:09:11.691124+00:00","updated_at":"2026-06-17T17:09:11.691124+00:00","problems":[],"ecosystem":"crates","meta_description":null,"install_score":null,"quickstart_score":null,"quickstart_tag":null,"pypi_latest":null,"cli_name":null,"cli_version":null,"type":"library","homepage":"https://github.com/TimelyDataflow/timely-dataflow","github":"https://github.com/TimelyDataflow/timely-dataflow","docs":"https://docs.rs/timely/","changelog":null,"pypi":null,"npm":null,"openapi_spec":null,"status_page":null,"smithery":null,"categories":["async"],"base_url":null,"auth_type":null,"provenance":{"verified_status":null,"verified_at":null,"last_verified":"2026-06-17","next_check":"2026-12-14","install_tag":null}}