13 个版本
| 0.2.0 | 2021年12月26日 |
|---|---|
| 0.1.11 | 2021年12月4日 |
| 0.1.9 | 2021年11月24日 |
| 0.1.8 | 2021年9月6日 |
| 0.1.5 | 2021年8月22日 |
#8 in #data-engineering
219 每月下载量
用于 19 crates
180KB
5.5K SLoC
内置在 pipebase is a tokio based runtime library for data integration app. It provides basic pipe
基本管道
pipebase 中的基本管道列表
| 管道类型 | 实现 | 示例 |
|---|---|---|
导出器 |
打印机 |
打印机 |
轮询器 |
计时器 |
计时器 |
监听器 |
本地文件路径访问者 |
文件路径 |
流式传输器 |
文件行读取器 |
无状态词计数 |
流式传输器 |
迭代器读取器 |
无状态词计数 |
映射器 |
字段访问 |
字段过滤器 |
映射器 |
过滤映射 |
字段过滤器 |
映射器 |
字符串分割器 |
无状态词计数 |
映射器 |
投影 |
文件投影 |
映射器 |
文件读取器 |
文件投影 |
映射器 |
文件写入器 |
转换 CSV |
映射器 |
转换 |
转换 CSV |
选择器 |
随机选择器 |
并行摄入 Redis |
收集器 |
文本收集器 |
摄入 Elasticsearch |
收集器 |
内存窗口收集器 |
移动平均 |
依赖项
~7–15MB
~171K SLoC