#apache #flink #stateful #sdk #function #html #org-stateful-functions

statefun

Apache Flink 状态函数(StateFun)项目的 Rust SDK。查看:https://flink.apache.org/stateful-functions.html

2 个不稳定版本

0.2.0-alpha.22023年7月4日
0.1.1 2020年7月8日
0.1.0 2020年7月5日

#2077 in 网页编程

27 每月下载量

MIT 许可证

81KB
1.5K SLoC

Statefun Rust SDK

用于在 Rust 中编写状态函数的 SDK。有关项目的更多信息,请参阅 Apache Flink 状态函数 网站。

支持的 StateFun API 版本

该库目前针对 Statefun v3.2.0

Apache Statefun v3.x 的变化

请注意,Apache Statefun v3.x 有 API 破坏性更改。此版本的 Rust SDK 仅支持 Apache Statefun 协议的 v3.x。

请注意,此 Rust SDK 的新版本需要用户代码实现新的 SerializableTypeName 特性。请参考示例代码了解如何自行实现。

验证和支持

请注意,此项目由志愿者维护,并由 Apache Flink Statefun 项目官方不支持。

此外,某些功能和方法验证可能缺失(例如,对函数类型名称的长度/字符集的验证)。

如何使用

./examples 目录中提供了几个示例。有关更多信息,请参阅每个示例的 README 文件。

请参阅 文档 了解如何设置和使用 Statefun 集群。

构建

您需要将 Protobuf 编译器 protoc 安装到您的 $PATH 中。在 macOS 上,您可以通过以下方式安装它:

brew install protobuf

依赖关系

~12MB
~203K SLoC