Directories
¶
| Path | Synopsis |
|---|---|
|
Package dataflow provides a lightweight data pipeline framework for ETL tasks.
|
Package dataflow provides a lightweight data pipeline framework for ETL tasks. |
|
app
Package app 提供应用程序框架。
|
Package app 提供应用程序框架。 |
|
builtins/processor/aggregate
Package aggregate 提供分组聚合处理器
|
Package aggregate 提供分组聚合处理器 |
|
builtins/processor/condition
Package condition 提供条件过滤处理器
|
Package condition 提供条件过滤处理器 |
|
builtins/processor/expr
Package expr 提供表达式过滤处理器
|
Package expr 提供表达式过滤处理器 |
|
builtins/processor/jqtransform
Package jqtransform 提供基于 jq 语法的超级转换处理器
|
Package jqtransform 提供基于 jq 语法的超级转换处理器 |
|
builtins/processor/transform
Package transform 提供字段转换处理器
|
Package transform 提供字段转换处理器 |
|
builtins/python/processor
Package processor 提供 Python 脚本 Processor 实现。
|
Package processor 提供 Python 脚本 Processor 实现。 |
|
builtins/python/runner
Package runner 提供 Python 子进程运行器。
|
Package runner 提供 Python 子进程运行器。 |
|
builtins/python/sink
Package sink 提供 Python 脚本 Sink 实现。
|
Package sink 提供 Python 脚本 Sink 实现。 |
|
builtins/python/source
Package source 提供 Python 脚本 Source 实现。
|
Package source 提供 Python 脚本 Source 实现。 |
|
builtins/sink/clickhouse
Package clickhouse 提供 ClickHouse 批量写入 Sink 支持批量写入、定时刷新和可选的字段映射
|
Package clickhouse 提供 ClickHouse 批量写入 Sink 支持批量写入、定时刷新和可选的字段映射 |
|
builtins/sink/collect
Package collect 提供内存收集的 Sink，主要用于测试
|
Package collect 提供内存收集的 Sink，主要用于测试 |
|
builtins/sink/csv
Package csv 提供写入 CSV 文件的 Sink
|
Package csv 提供写入 CSV 文件的 Sink |
|
builtins/sink/json
Package json 提供写入 JSON 文件的 Sink
|
Package json 提供写入 JSON 文件的 Sink |
|
builtins/sink/null
Package null 提供丢弃数据的 Sink，用于性能测试
|
Package null 提供丢弃数据的 Sink，用于性能测试 |
|
builtins/sink/output
Package output 提供控制台输出的 Sink
|
Package output 提供控制台输出的 Sink |
|
builtins/source/csv
Package csv 提供从 CSV 文件读取数据的 Source
|
Package csv 提供从 CSV 文件读取数据的 Source |
|
builtins/source/generator
Package generator 提供序列数据生成器
|
Package generator 提供序列数据生成器 |
|
builtins/source/json
Package json 提供从 JSON 文件读取数据的 Source
|
Package json 提供从 JSON 文件读取数据的 Source |
|
builtins/source/kafka
Package kafka 提供从 Kafka Topic 消费消息的 Source
|
Package kafka 提供从 Kafka Topic 消费消息的 Source |
|
builtins/source/static
Package static 提供静态内存数据源
|
Package static 提供静态内存数据源 |
|
builtins/types
Package types 提供内置组件的共享类型定义
|
Package types 提供内置组件的共享类型定义 |
|
metrics
Package metrics 提供 Prometheus 指标收集和暴露功能
|
Package metrics 提供 Prometheus 指标收集和暴露功能 |
|
Package logger 提供基于 zap 的全局日志功能
|
Package logger 提供基于 zap 的全局日志功能 |
Click to show internal directories.
Click to hide internal directories.