SQL操作：Select (Select)

Java 类名：com.alibaba.alink.pipeline.sql.Select

Python 类名：Select

功能介绍

提供 SQL 的 SELECT 语句功能。

使用方式

该组件提供与 SelectBatch/StreamOp 相近的功能。

该组件既可以单独使用（直接调用 transform方法），也可以置于构建 Pipeline 中使用。 前一种场景的使用方式跟 SelectBatch/StreamOp 一致。

后一种场景时，有两点需要特别注意：

1. 语句需要严格输入 1 行输出 1 行，即满足 map 的功能；
2. 因为内部实现实际采用的是 Calcite 而非 Flink，因此可能不支持某些 Flink
   内置方法；经过测试可以使用的内置方法可以见测试代码
   。

参数说明

名称	中文名称	描述	类型	是否必须？	取值范围	默认值
clause	运算语句	运算语句	String	✓

代码示例

Python 代码

URL = "https://alink-test-data.oss-cn-hangzhou.aliyuncs.com/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)
select = Select().setClause("category as label")
select.transform(data).print()

Java 代码

import com.alibaba.alink.operator.batch.BatchOperator;
import com.alibaba.alink.operator.batch.source.CsvSourceBatchOp;
import com.alibaba.alink.pipeline.sql.Select;
import org.junit.Test;

public class SelectTest {
	@Test
	public void testSelect() throws Exception {
		String URL = "https://alink-test-data.oss-cn-hangzhou.aliyuncs.com/iris.csv";
		String SCHEMA_STR
			= "sepal_length double, sepal_width double, petal_length double, petal_width double, category string";
		BatchOperator <?> data = new CsvSourceBatchOp().setFilePath(URL).setSchemaStr(SCHEMA_STR);
		Select select = new Select().setClause("category as label");
		select.transform(data).print();
	}
}

运行结果

label
Iris-versicolor
Iris-setosa
Iris-setosa
Iris-setosa
Iris-virginica
…
Iris-setosa
Iris-versicolor
Iris-virginica
Iris-setosa
Iris-versicolor