* quoteCharacter: Character
* 设置一个引号字符,启用带引号的字符串解析
* 如果字段的第一个字符是引号字符,则字符串将被解析为带引号的字符串,引号字符串中的字段分隔符将被忽略...* 如果带引号的字符串字段的最后一个字符不是引号字符,则引用的字符串解析将会失败
* 如果启用了带引号的字符串解析并且该字段的第一个字符不是引号字符串,则该字符串将被解析为不带引号的字符串...],指定映射到CSV字段的POJO的字段,CSV字段的解析器将根据POJO字段的类型和顺序自动初始化
)
ds1.print()
println("--------------...、端口、行分隔符以及重试的时间间隔
val source: DataStream[String] = env.socketTextStream("beh07", 9999, '\n', 1)...自定义数据源
以读取MySQL中的数据为例
首先完成自定义Source类的开发
import java.sql.