| BatchNode |
顶级节点,定义了批数据源 |
0 |
3 |
| StreamNode |
顶级节点,定义了流数据源 |
0 |
3 |
| QueryNode |
只能跟着BatchNode |
2 |
28 |
| FromNode |
只能跟着StreamNode |
1 |
28 |
| SideloadNode |
基于来自各种源的分层数据向点添加字段和标签 |
31 |
29 |
| DefaultNode |
用于为数据系列中的tag和field设置默认值 |
31 |
29 |
| ShiftNode |
用于移动数据点时间戳 |
31 |
29 |
| WhereNode |
用于过滤 |
30 |
29 |
| WindowNode |
用于在移动时间范围内缓存数据 |
31 |
29 |
| CombineNode |
用于将来自单个节点的数据与自身组合在一起 |
31 |
29 |
| EvalNode |
用于对表达式命名 |
31 |
29 |
| GroupByNode |
按照标签Tag对传如数据进行分组 |
29 |
29 |
| JoinNode |
根据匹配的时间戳连接来自任意数量管道的数据 |
31 |
29 |
| UnionNode |
可以将任意数量的管道进行联合 |
31 |
29 |
| DeleteNode |
从数据点删除字段Field和标记Tag |
31 |
29 |
| DerivativeNode |
求导数 |
31 |
29 |
| FattenNode |
在特定维度上展平一组点 |
31 |
29 |
| InfluxQLNode |
提供对InfluxQL功能的访问 |
31 |
29 |
| StateDurationNode |
计算给定状态持续时间 |
31 |
29 |
| StatsNode |
给定时间间隔发出有关另一个节点内部统计信息 |
35 |
29 |
| BarrierNode |
可以在没有数据流量的情况下执行管道 |
31 |
29 |
| ChangeDetectNode |
如果字段值发生变化则创建节点 |
31 |
29 |
| StateCountNode |
计算连续点的在一个给定的状态的数目 |
31 |
29 |
| AlertNode |
配置警报发射 |
33 |
27 |
| DeadmanNode |
实际上是辅助函数,它是alert当数据流低于指定阈值时触发的别名 |
0 |
0 |
| HTTPOutNode |
为其收到的每个组缓存最新数据,使用字符串参数作为最终定位器上下文,使其可通过Kapicator http服务器使用 |
31 |
29 |
| HTTPPostNode |
将数据发布到字符串数组中指定的HTTP端点 |
31 |
29 |
| InfluxDBOutNode |
在收到数据时将数据写入InfluxDB |
31 |
1 |
| K8sAutoscaleNode |
触发Kubernetes™资源的自动缩放 |
31 |
29 |
| KapacitorLoopback |
将数据写回kapacitor流 |
31 |
1 |
| SwarmAutoscaleNode |
触发Docker Swarm模式集群上的服务的自动调度事件。该节点还输出触发事件的点 |
30 |
29 |
| EC2AutoscaleNode |
触发AWS Autoscaling组上的组的自动调度事件 |
31 |
29 |
| LogNode |
记录通过它的所有数据 |
30 |
29 |
| UDFNode |
实现由用户或脚本定义的功能 |
0 |
29 |
| NoOpNode |
不要用 |
0 |
29 |