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