Я пробовал это, используя приведенный ниже код, который работает нормально.
`var basePath = "<Full_Path>"
var files = Array[String]()
var maxTS: Long = 0
var TimeFile = collection.mutable.Map[Long, String]()
val conf = new Configuration()
val hdfs = FileSystem.get( conf )
val f = new Path( basePath )
val messageFile = hdfs.listFiles( f, true )
while (messageFile.hasNext()) {
val message = messageFile.next()
if (message.getPath.toString().endsWith( "tsv" )) {
files = files :+ message.getPath.toString()
TimeFile += ( message.getModificationTime -> message.getPath.toString())
}
}`