Создать каталог на удаленных hdfs из localhost, используя Java - PullRequest
0 голосов
/ 30 мая 2019

Создать каталог на удаленной HDFS из localhost

Написанный код, но не понимаю, что и где писать core-site.xml и hdfs-site.xml.

public class HadoopCall {

    public void demomkdir(String dir) throws IOException
    {
        Configuration obj = new Configuration();

        obj.set("fs.defaultFS", "http://datlpdsnn01.pds.in.****.com:50070/");
        FileSystem fs = FileSystem.get(obj);

        Path pth = new Path(dir);
        fs.mkdirs(pth);
        System.out.println("created");
        fs.close(); 
    }

    public static void main(String[] args) throws IOException {
        HadoopCall oj = new HadoopCall();
        oj.demomkdir("user/*******/javacodemkdir");
    }

}

1 Ответ

0 голосов
/ 30 мая 2019

Ссылка: Класс конфигурации Hadoop

Как указано в приведенной выше ссылке:

core-default.xml: значения по умолчанию только для hadoop.

core-site.xml: специфичная для сайта конфигурация для данного hadoop установка.

Оба файла имеют конфигурацию, специфичную для установки, и настройки по умолчанию. Вы можете добавить путь к любому из приведенных выше XML с помощью метода addResource (Path path) . Если пути не указаны, пути к файлам xml выводятся из переменных classpath.

...