Description

Filter records in the stream operator.

Parameters

Script Example

Code

URL = "https://alink-release.oss-cn-beijing.aliyuncs.com/data-files/iris.csv"
SCHEMA_STR = "sepal_length double, sepal_width double, petal_length double, petal_width double, category string";
data = CsvSourceStreamOp().setFilePath(URL).setSchemaStr(SCHEMA_STR)
data = data.link(FilterStreamOp().setClause("category='Iris-setosa'"))