重命名在hadoop中创建的文件-Spark

tec*_*hie 0 hadoop apache-spark spark-dataframe

通过写入在HDFS中创建的文件具有其自己的命名约定。要将其更改为自定义名称,可以通过脚本使用hadoop fs -mv oldname newname

Spark / Hadoop中是否有其他可用选项可为创建的文件提供自定义名称。

Ami*_*mar 5

Apache Spark不为hdfs中的文件系统操作提供任何Api。但是您始终可以使用Hadoop文件系统API重命名HDFS中的文件。选中此项以获取可用的Hadoop文件系统API的更多详细信息。对于重命名,以下操作将起作用:

val conf = new Configuration();
val fileSystem = FileSystem.get(conf);
fileSystem.mkdir(new Path(newhdfs_dirPath));
fileSystem.rename(new Path(existinghdfs_dirpath+oldname), new Path(newhdfs_dirPath+newname));
Run Code Online (Sandbox Code Playgroud)