- 功能介绍
- 参数说明
- 脚本示例
- 脚本代码
- 脚本代码
功能介绍
提供sql的order by语句功能
参数说明
名称 | 中文名称 | 描述 | 类型 | 是否必须? | 默认值 | |
---|---|---|---|---|---|---|
fetch | fetch的record数目 | fetch的record数目 | Integer | |||
limit | record的limit数 | record的limit数 | Integer | |||
offset | fetch的偏移值 | fetch的偏移值 | Integer | |||
order | 排序方法 | 排序方法 | String | “asc” | ||
clause | 运算语句 | 运算语句 | String | ✓ |
脚本示例
脚本代码
URL = "http://alink-dataset.cn-hangzhou.oss.aliyun-inc.com/csv/iris.csv"
SCHEMA_STR = "sepal_length double, sepal_width double, petal_length double, petal_width double, category string";
data = CsvSourceBatchOp().setFilePath(URL).setSchemaStr(SCHEMA_STR)
data = data.link(OrderByBatchOp().setLimit(10).setClause("sepal_length"))