HDFS バックエンド¶

HDFSBackend インタフェース¶

このクラスは、HDFS バックエンド実装が公開する必要があるメソッドを列挙します。この場合、次のものがあります :

void createDir(String dirPath) throws Exception;

パスを指定して HDFS ディレクトリを作成します。

void createFile(String filePath, String data) throws Exception;

パスを指定して HDFS ファイルを作成し、そのファイルに初期データを書き込みます。

void append(String filePath, String data) throws Exception;

既存の HDFS ファイルに新しいデータを追加します。

boolean exists(String filePath) throws Exception;

パスが指定された HDFS ファイルが存在しないかどうかをチェックします。

HDFSBackendImpl クラス¶

これは HttpBackend 抽象クラスを拡張する HDFS の便利なバックエンドクラスであり(Http接続ベースのバックエンドの共通ロジックを提供します)、上記の HDFSBackend インタフェースを実装します。

HDFSBackendImpl は、実際に WebHDFS API をラップします。

このバックエンドの実装では、Content-Typehttp ヘッダの text/plain; charset=utf-8 値を使用して UTF-8 エンコーディングを強制する必要があります。