文件名称：基于集合的数据源-惯性导航（秦永元编著）
文件大小：1.66MB
文件格式：PDF
更新时间：2024-07-21 12:17:20
Flink 大数据
5.1 基于File的数据源 ⼀一列列⼀一列列的读取遵循TextInputFormat规范的⽂文本⽂文件，并将结果作为String返回。 readTextFile 5.2 基于Socket的数据源 从Socket中读取信息，元素可以⽤用分隔符分开。 socketTextStream 5.3 基于集合的数据源 val env = StreamExecutionEnvironment.getExecutionEnvironment val inputStream = env.readTextFile(args(0)) inputStream.print() env.execute("hello-world") val inputStream = env.socketTextStream("localhost", 8888)