PiflowX组件 - Filter
2024-01-07 22:35:41
Filter组件
组件说明
数据过滤。
计算引擎
flink
组件分组
common
端口
Inport:默认端口
outport:默认端口
组件属性
名称 | 展示名称 | 默认值 | 允许值 | 是否必填 | 描述 | 例子 |
---|---|---|---|---|---|---|
condition | condition | “” | 无 | 是 | 过滤条件。 | age >= 50 or age < 20 |
Filter示例配置
{
"flow": {
"name": "FilterTest",
"uuid": "1234",
"stops": [
{
"uuid": "0000",
"name": "MockData1",
"bundle": "cn.piflow.bundle.flink.common.DataGen",
"properties": {
"schema": "[{\"filedName\":\"id\",\"filedType\":\"INT\",\"kind\":\"sequence\",\"start\":1,\"end\":10000},{\"filedName\":\"name\",\"filedType\":\"STRING\",\"kind\":\"random\",\"length\":15},{\"filedName\":\"age\",\"filedType\":\"INT\",\"kind\":\"random\",\"max\":100,\"min\":1}]",
"count": "500",
"ratio": "1"
}
},
{
"uuid": "2222",
"name": "Filter1",
"bundle": "cn.piflow.bundle.flink.common.Filter",
"properties": {
"condition": "age >= 50 or age < 20"
}
},
{
"uuid": "3333",
"name": "ShowData1",
"bundle": "cn.piflow.bundle.flink.common.ShowData",
"properties": {
"showNumber": "100"
}
}
],
"paths": [
{
"from": "MockData1",
"outport": "",
"inport": "",
"to": "Filter1"
},
{
"from": "Filter1",
"outport": "",
"inport": "",
"to": "ShowData1"
}
]
}
}
示例说明
本示例演示了通过DataGen
组件生成id,name,age 3个字段500条数据,每秒生成1条数据,使用Filter
组件过滤数据,过滤条件为age >= 50 or age < 20
,然后使用ShowData
组件将过滤后的数据打印在控制台。
生成字段描述
[
{
"filedName": "id",
"filedType": "INT",
"kind": "sequence",
"start": 1,
"end": 10000
},
{
"filedName": "name",
"filedType": "STRING",
"kind": "random",
"length": 15
},
{
"filedName": "age",
"filedType": "INT",
"kind": "random",
"max": 100,
"min": 1
}
]
1.id字段
id字段类型为INT,使用sequence生成器,序列生成器的起始值为1,结束值为10000.
2.name字段
name字段类型为STRING,使用random生成器,生成字符长度为15。
3.age字段
age字段类型为INT,使用random生成器,随机生成器的最小值为1,最大值为100。
欢迎关注PiflowX公众号,谢谢支持!!!
文章来源:https://blog.csdn.net/qq_19635589/article/details/135445137
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!