CSV 文本内容数据源(CsvContentSourceStreamOp)

Java 类名：org.alinklab.operator.stream.source.CsvContentSourceStreamOp

Python 类名：CsvContentSourceStreamOp

功能介绍

CSV 文本内容数据源

参数说明

名称	中文名称	描述	类型	是否必须？	取值范围	默认值
schemaStr	Schema	Schema。格式为“colname coltype[, colname2, coltype2[, …]]”，例如“f0 string, f1 bigint, f2 double”	String	✓
textContent	文本内容	文本内容	String	✓
fieldDelimiter	字段分隔符	字段分隔符	String		It can’t be empty string.	,
ignoreFirstLine	是否忽略第一行数据	是否忽略第一行数据	Boolean			false
lenient	是否容错	若为true，当解析失败时丢弃该数据；若为false，解析失败是抛异常	Boolean			false
printLimit	每个窗口内的最大输出条数	每个窗口内的最大输出条数	Integer			null
quoteChar	引号字符	引号字符	Character			"
rowDelimiter	行分隔符	行分隔符	String		It can’t be empty string.	\n
skipBlankLine	是否忽略空行	是否忽略空行	Boolean			true

代码示例

Java 代码