Lib.rs

› 关键词 #数据处理 #异步 #fluvio #数据流 #异步流 #处理器

#stream-processing

  1. sea-streamer

    🌊 Rust 的流处理工具包

    v0.5.0 1.8K #async-stream #流处理 #流 #kafka #异步-i/o #异步 #异步-api

  2. fiddler-cli

    使用 Rust 编写的数据流处理器 CLI

    v0.3.1 250 #流处理 #yaml 配置 #配置文件 #python #cli #处理器 #输入

  3. callysto

    流处理框架

    v0.1.11 #流处理 #流 #微服务 #分布式 #分布式数据库 #数据库

  4. fluvio-types

    Fluvio 公共类型和对象

    v0.5.0 2.1K #fluvio #数据处理 #数据流 #类型 #分布式 #流处理 #有状态

  5. indicator

    用于流聚合的抽象，我们称之为 Indicator

    v0.4.4 120 #流处理 #流 #聚合 #无标准

  6. dapt

    序列化和反序列化非结构化数据

    v0.1.9 #序列化 #数据处理 #流处理 #数据流 #非结构化 #反序列化 #数据结构

  7. fluvio-stream-model

    Fluvio 事件流模型

    v0.11.4 650 #数据处理 #fluvio #事件流 #数据流 #数据管道 #流处理 #分布式系统

  8. xstream-util

    一个命令行工具，可以将流分割成子进程

    v2.0.0 #子进程 #流 #命令行工具 #并行处理 #流处理 #分割 #分隔符

  9. fluvio-stream-dispatcher

    Fluvio 事件流访问

    v0.13.4 550 #事件流 #fluvio #数据流 #事件 #流处理 #数据处理 #事件流

  10. fluvio-protocol

    Fluvio 流协议

    v0.11.0 2.0K #event-driven-architecture #data-pipeline #fluvio #stream-processing #real-time #data-processing #protocols

  11. fluvio-extension-common

    Fluvio 扩展通用

    v0.14.1 130 #fluvio #extension #stream-processing #real-time #event-driven-architecture #serverless #data-pipeline

  12. cesrox

    可组合事件流表示（CESR）

    v0.1.4 340 #event-streaming #cesr #data-encoding #stream-processing #events #data-stream #text-encoding

  13. multistream-batch

    批处理算法的实现

    v1.2.0 120 #batch #multiline #transaction #stream-processing

  14. fiddler

    用 rust 编写的数据流处理器

    v0.3.1 #config-file #yaml-config #stream-processing #python #processor #input #pipeline

  15. sea-streamer-examples

    🌊 Rust 的流处理工具包

    v0.5.0 200 #stream-processing #processor #producer #producer-consumer #data-processing #data-stream #batch

  16. fluvio-spu-schema

    Fluvio API for SPU

    v0.15.0 500 #stream-processing #fluvio #real-time #event-driven-architecture #spu #streaming #data-pipeline

  17. sea-streamer-socket

    🌊 SeaStreamer 无后端 Socket API

    v0.5.0 1.8K #stream-processing #async-stream #stream #kafka #async #data-stream #back-end

  18. sea-streamer-file

    🌊 SeaStreamer 文件后端

    v0.5.2 1.8K #data-stream #stream #async-stream #stream-processing #async #data-file #file-format

  19. noir-compute

    Rust 中的算子网络

    v0.2.0 #data-processing #stream-processing #operator #distributed #block #dataflow #noir

  20. sea-streamer-stdio

    🌊 SeaStreamer 标准I/O后端

    v0.5.0 1.8K #stream-processing #async-stream #stream #async #back-end #data-processing #processor

  21. sea-streamer-redis

    🌊 SeaStreamer Redis后端

    v0.5.0 1.8K #redis #stream-processing #stream #async-stream #async #back-end #redis-cluster

  22. navactor

    一个从管道输入创建和更新actor的命令行工具

    v0.5.3 150 #actor #iot #digital #command-line #actor-model #twin #stream-processing

  23. deluge

    一个高性能流库，可以驱动底层的future以并发或并行的方式尽可能快地处理流操作

    v0.2.1 #future #async #stream-processing #futures

  24. rlink

    高性能流处理框架

    v0.6.16 #stream-processing #stream #flink #kubernetes-cluster #window

  25. sea-streamer-kafka

    🌊 SeaStreamer Kafka / Redpanda 后端

    v0.5.0 1.8K #kafka #stream-processing #async-stream #stream #async #apache-kafka #back-end

  26. dbsp

    连续流分析引擎

    v0.2.0 #stream-processing #data-stream #analytics #streaming #database

  27. sea-streamer-types

    🌊 SeaStreamer 特性和类型

    v0.5.0 1.9K #stream-processing #async-stream #stream #async

  28. par-stream

    类似于rayon的异步并行流

    v0.10.2 3.0K #stream-processing #parallel-processing #data-processing #async #async-io #dataflow

  29. swimos_client

    SwimOS 客户端

    v0.1.0 #swim-os #client #real-time #stateful #streaming #data-integration #stream-processing

  30. rspl

    流处理器语言

    v0.1.2 #stream-processing #event-driven #language #functional-programming #state-machine #demand-driven

  31. online-statistics

    极快、通用、可序列化的在线统计

    v0.2.6 #online #stream #stats #generic #statistics #stream-processing #serializable

  32. watermill

    极快、通用、可序列化的在线统计

    v0.1.1 1.4K #statistics #stream #online #stream-processing #update #quantile #serializable

  33. iterpipes

    组合的管道风格流处理

    v0.2.0 #pipe #stream-processing #iterator #pipeline #input #compositional #next

  34. springql

    面向物联网设备和车载计算机的开源流处理程序

    v0.18.1 #流处理 #物联网设备 #计算机 #处理器 #低查询 #连续

  35. fluvio-dataplane-protocol

    数据平面协议

    v0.11.6 1.0K #流处理 #fluvio #分布式系统 #协议 #实时 #流式传输 #云原生

  36. fluvio-runner-local

    Fluvio 引擎运行器

    v0.3.0 #流处理 #数据流 #数据处理 #fluvio #数据管道 #数据集成 #数据流

  37. d-rs

    命令行中的流处理实用工具

    v0.2.0 #命令行 #流处理 #数据流 #数据处理 #awk #grep #sed

  38. nature-demo

    Nature 使用演示

    v1.5.0 190 #nature #如何 #工作流 #系统 #平台 #数据流 #流处理

  39. rlink-connector-kafka

    高性能流处理框架

    v0.6.6 #流处理 #kafka #流 #flink #窗口

  40. iomux

    多路复用标准输出、标准错误和其他子命令信息

    v0.1.0 #子进程 #输出流 #命令 #流处理 #命令输出 #退出状态 #信息

  41. rust-stream-ext-concurrent

    为任何 futures::stream::Stream 对象提供并发行为扩展

    v1.0.0 #流 #未来 #扩展 #流处理 #并发 #对象 #行为

  42. parallel_reader

    并行读取文件（或任何 Read 流），并按块进行处理

    v0.1.2 #读取流 #流处理 #块 #并行 #读取 #读取文件 #线程

  43. sgdata

    分散、聚合、不可变、arc-ed 数据

    v0.2.0 #数据处理 #备份 #加密 #去重 #去重 #数据流 #流处理

  44. hadron-client

    Hadron Rust 客户端库

    v0.1.0-beta.1 #事件 #工作流 #云事件 #流处理 #hadron #API 绑定

  45. callysto-avro

    为 Callysto 流处理框架提供的 Avro serde

    v0.1.2 #流处理 #流 #微服务 #分布式 #分布式数据库 #序列化 #数据库

  46. rlink-connector-elasticsearch

    高性能流处理框架

    v0.6.1 #流处理 #elasticsearch #流 #窗口 #flink

  47. rlink-connector-clickhouse

    高性能流处理框架

    v0.6.1 #流处理 #clickhouse #流 #flink #窗口

  48. hamlet

    流处理的HTML标记定义

    v0.2.1 #html #token #流处理 #token-stream #definition #tags #attr

  49. rlink-connector-files

    高性能流处理框架

    v0.5.0 #流处理 #hdfs #流 #flink #窗口

    50. 尝试使用DuckDuckGo进行搜索。

  50. event-stream-processor

    服务器端事件的流处理器

    v1.0.0 #事件流 #事件 #服务器端 #流处理 #处理器 #格式

  51. springql-core

    SpringQL：开源的物联网设备和车载计算机的流处理器

    v0.18.1 130 #流处理 #物联网设备 #spring-ql #低内存 #SQL查询 #任务调度器 #springql

  52. arcon_error

    Arcon的常见错误工具

    v0.1.1 #分布式计算 #错误 #arcon #工具 #部分 #流处理 #数据分析

  53. redis-streams-dump

    一个小工具，用于将Redis Streams内容导出到SeaStreamer文件中

    v0.3.0 #流 #redis #异步流 #流处理 #输出流 #异步

  54. arcon_state

    为Arcon提供的状态管理功能

    v0.2.1 #状态管理 #arcon #分布式计算 #数据流 #流处理

  55. indicator_macros

    用于流聚合的抽象，我们称之为 Indicator

    v0.4.4 #聚合 #流 #流处理 #无标准

  56. dashpipe

    为dashpipe流处理提供核心库

    v0.0.3 #流式 #流量 #可观测性 #流处理

  57. spaniel

    流处理网络库（SPNL）的基本实现

    v0.1.0 #流处理 #网络 #spnl

  58. rlink-derive

    高性能流处理框架

    v0.3.0 #流 #流处理 #窗口 #flink

  59. mysqldump-mutator

    使用 Rust 编写的 MySQL mysqldump 流处理器/转换器

    v0.0.1 #mysql #backup #mutate #anonymize #stream-processing #mysqldump

  60. 河流

    流处理库

    v0.0.1 #stream-processing #stream #processing

  61. indicator_derive

    用于流聚合的抽象，我们称之为 Indicator

    v0.4.1-alpha.0 #aggregation #stream #stream-processing #no-std

  62. antimony

    Antimony 的拓扑构建器包

    v0.0.1 #stream-processing #distributed #real-time #drpc

  63. near-event-stream-processor

    处理 NEAR 事件流

    v0.0.1 #event-stream #event #near #event-streaming #streaming #stream-processing

  64. arcon_spec

    Arcon 规范

    v0.1.3 #specification #arcon #distributed-computing #data-analytics #stream-processing #deprecated #moved