该文档涉及的组件

    Text文件数据源 (TextSourceStreamOp)

    Java 类名:com.alibaba.alink.operator.stream.source.TextSourceStreamOp

    Python 类名:TextSourceStreamOp

    功能介绍

    按行读取文本文件的数据。

    参数说明

    名称 中文名称 描述 类型 是否必须? 取值范围 默认值
    filePath 文件路径 文件路径 String
    ignoreFirstLine 是否忽略第一行数据 是否忽略第一行数据 Boolean false
    partitions 分区名 1)单级、单个分区示例:ds=20190729;2)多级分区之间用“ / ”分隔,例如:ds=20190729/dt=12; 3)多个分区之间用“,”分隔,例如:ds=20190729,ds=20190730 String null
    textCol 文本列名称 文本列名称 String “text”

    代码示例

    Python 代码

    from pyalink.alink import *
    
    import pandas as pd
    
    useLocalEnv(1)
    
    URL = "https://alink-test-data.oss-cn-hangzhou.aliyuncs.com/iris.csv"
    data = TextSourceStreamOp().setFilePath(URL).setTextCol("text")
    data.print()
    StreamOperator.execute()
    

    Java 代码

    import com.alibaba.alink.operator.stream.StreamOperator;
    import com.alibaba.alink.operator.stream.source.TextSourceStreamOp;
    import org.junit.Test;
    
    public class TextSourceStreamOpTest {
    	@Test
    	public void testTextSourceStreamOp() throws Exception {
    		String URL = "https://alink-test-data.oss-cn-hangzhou.aliyuncs.com/iris.csv";
    		StreamOperator <?> data = new TextSourceStreamOp().setFilePath(URL).setTextCol("text");
    		data.print();
    		StreamOperator.execute();
    	}
    }
    

    运行结果

    text
    5.0,3.2,1.2,0.2,Iris-setosa
    6.6,3.0,4.4,1.4,Iris-versicolor
    5.4,3.9,1.3,0.4,Iris-setosa
    5.0,2.3,3.3,1.0,Iris-versicolor