Search

Lib.rs

›
#stream-processing #stream-processing-engine #flow #sql #data-fusion

bin+lib arkflow

High-performance Rust flow processing engine

by chen quan

  • Install
  • API reference
  • GitHub (chenquan)

1 unstable release

0.1.0 Mar 10, 2025

#12 in #stream-processing-engine

Apache-2.0

115KB
2.5K SLoC

Rust流处理引擎

Dependencies

~200MB
~4.5M SLoC

  • anyhow
  • arrow-json 54.0
  • async-trait
  • aws-msk-iam-sasl-signer
  • axum 0.6
  • clap 4.3+derive
  • colored 2.0
  • datafusion 46.0
  • dyn-clone
  • flume
  • futures
  • humantime
  • lazy_static
  • prometheus 0.13
  • prost-reflect 0.14.7
  • prost-types 0.13.5
  • protobuf 3.7
  • protobuf-parse
  • rdkafka 0.37+cmake-build+tracing+sasl+ssl-vendored+zstd
  • rdkafka-sys
  • regex
  • reqwest 0.12+json
  • rumqttc 0.24
  • sasl2-sys+vendored
  • serde+derive
  • serde_json
  • serde_yaml 0.9
  • thiserror 2.0
  • tokio+full
  • toml 0.7
  • tracing
  • tracing-subscriber
  • waitgroup
Related: arkflow-core, arkflow-plugin
See also: datafusion-functions-json, datafusion-sql, fluvio-stream-model, fluvio-stream-dispatcher, datafusion, k8sql, datafusion-federation, datafusion-server, datafusion-table-providers, datafusion-physical-expr, arroyo-udf-common

Lib.rs is an unofficial list of Rust/Cargo crates, created by kornelski. It contains data from multiple sources, including heuristics, and manually curated data. Content of this page is not necessarily endorsed by the authors of the crate. This site is not affiliated with nor endorsed by the Rust Project. If something is missing or incorrect, please file a bug.