PiflowX组件 - Filter-编程知识

PiflowX组件 - Filter

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  
}  
]