inputs

dataframe

inputs为字典类型，dataframe为pyspark中的DataFrame类型对象

output

output_port_1

output为字典类型，output_port_1为pyspark中的DataFrame类型对象，为数据集过滤结果

column_name

是

列名，对该列按照过滤条件进行数据集的行过滤，不同列之间用分号分隔

无

condition_map_str

是

过滤条件组装后的格式化字符串，格式参考：”!=:filter_value;IS NULL;BETWEEN:left_value,right_value;REGEXP:expr”

该字符串将被分号分割为多个条件，每个条件对应的字符串将被冒号分割为过滤条件和过滤值，最终将被转换成如下字典：

{

“=”: “filter_value”,

“!=”: “filter_value”,

“>”: “filter_value”,

“>=”: “filter_value”,

“<": "filter_value",

“<=": "filter_value",

“IS NULL”: “”,

“IS NOT NULL”: “”,

“BETWEEN”: “filter_value_left,filter_value_right”,

“NOT BETWEEN”: “filter_value_left,filter_value_right”,

“LIKE”: “filter_value_expr”,

“NOT LIKE”: “filter_value_expr”,

“REGEXP”: “filter_value_expr”

}

无