コンストラクターの詳細

• HadoopUtils

  public HadoopUtils(XdEnvironment xdEnvironment)

  環境で指定された名前ノードを使用して Hadoop ユーティリティを初期化します。

  パラメーター:

  xdEnvironment - テストのための環境。

メソッドの詳細

• listDir

  public java.util.Collection<org.apache.hadoop.fs.FileStatus> listDir(java.lang.String path)

  指定されたパスにある HDF 内のエントリのリストを取得します。

  パラメーター:

  path - パス

  戻り値:

  リクエストされたパスのエントリのコレクション

• fileExists

  public boolean fileExists(java.lang.String uri)

  ファイルが存在することを確認します。

  パラメーター:

  uri - 検証するファイルの URI。

  戻り値:

  存在する場合は true、存在しない場合は false。

• fileRemove

  public void fileRemove(java.lang.String uri)

  ディレクトリ内のファイルを再帰的に削除します。ファイルのみの場合はそのファイルのみを削除します。

  パラメーター:

  uri - ファイルまたはディレクトリへのパス。

• getFileContentsFromHdfs

  public java.lang.String getFileContentsFromHdfs(java.lang.String path)

  hdfs ファイルシステムからファイルを取得します。

  パラメーター:

  path - 取得するファイルへの URI。

  戻り値:

  ファイルの文字列の内容。

• waitForPath

  public boolean waitForPath(int waitTime,
                    java.lang.String path)

  リソースが HDFs に書き込まれるまで、タイムアウトまで待機します。

  パラメーター:

  waitTime - 待機するミリ秒数。

  path - リソースへのパス。

  戻り値:

  パスが存在しない場合は false。存在する場合は true。

• getFileStatus

  public org.apache.hadoop.fs.FileStatus getFileStatus(java.lang.String filePath)

  指定されたファイルパスのファイルステータスを取得します。

  パラメーター:

  filePath - 調べるファイルのパス / ファイル名

  戻り値:

  ファイルの FileStatus。