首页 > TAG信息列表 > yangren
读写文件
1、从HDFS读取csv文件 val tagOriginDF = sparkSession.read.format("csv").option("header", "true").load("mdfs://cloudhdfs/pcgkg/user/yangren/origin/tag.csv") //指定分隔符 val queryDF = sparkSession.read.format("csv"读写文件
1、从HDFS读取csv文件 val tagOriginDF = sparkSession.read.format("csv").option("header", "true").load("mdfs://cloudhdfs/pcgkg/user/yangren/origin/tag.csv") //指定分隔符 val queryDF = sparkSession.read.format("csv"