Flink入门示例——wordCount(二)

说明(批处理) 读取HDFS数据 将处理结果写入HDFS 代码示例 package com.test import org.apache.flink.api.scala._ import org.apache.flink.core.fs.FileSystem.WriteMode /** * 读取hdfs数据,把处理结果结果再写入HDFS */ object WordCountBatch{
相关文章
相关标签/搜索