Синтаксис InputPath для SparkContext textFile

Question

Пожалуйста, расскажите, как мне нужно указать входной путь для textFile() с SparkContext. Как ниже, что не работает для меня.

sc.textFile("hdfs://localhost:54310/home/myFiles/sampleFile") 

В этом, 54310 это номер порта, указанный в core-site.xml

Answer 1

только простой ошибки. Расширение требуется для файлов мы загружаем в Спарк контексте

sc.textFile. (HDFS: // локальный: 54310/дома/MYFILES/sampleFile.txt ")