PiflowX组件 - Filter

2024-01-07 22:35:41

Filter组件

组件说明

数据过滤。

计算引擎

flink

组件分组

common

端口

Inport:默认端口

outport:默认端口

组件属性

名称展示名称默认值允许值是否必填描述例子
conditioncondition“”过滤条件。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
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。