Configuration conf = new Configuration(); // ユーザを指定する場合 conf.set(UnixUserGroupInformation.UGI_PROPERTY_NAME, "hoge,supergroup"); FileSystem fs = FileSystem.get(new URI("hdfs://hoge:9000/"), conf); // ディレクトリの作成など try { fs.getFileStatus(new Path("hoge")); } catch (FileNotFoundException e) { fs.mkdirs(new Path("hoge")); } // ファイルへの出力 // ex. 最後のフラグは上書き FSDataOutputStream dos = fs.create(new Path("hoge/hoge.txt"), true); dos.writeChars("テスト\n"); dos.close();
みたいに。
0 件のコメント:
コメントを投稿