コンストラクターの詳細

• XdEc2Validation

  public XdEc2Validation(HadoopUtils hadoopUtil,
                 XdEnvironment xdEnvironment)

  XdEc2Validation の新しいインスタンスを構築する

メソッドの詳細

• verifyXDAdminReady

  public void verifyXDAdminReady(java.net.URL adminServer)

  管理サーバーが利用可能であることを確認します。

  パラメーター:

  adminServer - 管理サーバーの場所

• assertReceived

  public void assertReceived(java.net.URL url,
                    java.lang.String streamName,
                    java.lang.String moduleName,
                    java.lang.String channelName,
                    int msgCountExpected)

  チャネルとモジュールのインスタンスが実際に正しい数のメッセージを処理したことを確認します。モジュール名には必ずインデックス番号 (例: .1) を付ける必要があることに注意してください。http | file のストリームがある場合、モジュールにアクセスするには、ソースのモジュール名を http.1、シンクのモジュール名を file.1 にする必要があります。

  パラメーター:

  url - ストリームがデプロイされるサーバー

  streamName - 分析するストリーム。

  moduleName - モジュールの名前。

  channelName - 照会するチャネルの名前。

  msgCountExpected - モジュールによって正常に処理されたと予想されるメッセージの数。

• assertReceived

  public void assertReceived(java.net.URL url,
                    java.lang.String streamName,
                    int msgCountExpected)

  ストリームを取得し、ストリーム内のすべてのモジュールがデータを処理したことを確認します。

  パラメーター:

  url - ストリームがデプロイされるサーバー

  streamName - 分析するストリーム。

  例外:

  java.lang.Exception - JSON の処理または HTTP GET リクエストの実行中にエラーが発生しました

• verifyTestContent

  public void verifyTestContent(java.net.URL url,
                       java.lang.String fileName,
                       java.lang.String data)

  ユーザーが提供したデータが、ストリームがフローを処理した後に保存されたものであることを確認します。

  パラメーター:

  url - ストリームがデプロイされるサーバー。

  fileName - チェックするデータが含まれるファイル。

  data - ストリームの結果を評価するために使用されるデータ。

• verifyLogContains

  public void verifyLogContains(java.net.URL url,
                       java.lang.String data)

  データがコンテナーログに含まれていることを確認します。

  パラメーター:

  url - コンテナーがデプロイされるサーバー。

  data - ログファイル内で検索される値。

• verifyContentContains

  public void verifyContentContains(java.net.URL url,
                           java.lang.String fileName,
                           java.lang.String data)

  ユーザーが提供したデータが結果に含まれていることを確認します。

  パラメーター:

  url - コンテナーがデプロイされるサーバー。

  fileName - チェックするデータが含まれるファイル。

  data - ストリームの結果を評価するために使用されるデータ。

• verifyContentContainsIgnoreCase

  public void verifyContentContainsIgnoreCase(java.net.URL url,
                                     java.lang.String fileName,
                                     java.lang.String data)

  ユーザーが提供したデータが結果に含まれていることを確認します。

  パラメーター:

  url - ストリームがデプロイされるサーバー。

  fileName - チェックするデータが含まれるファイル。

  data - ストリームの結果を評価するために使用されるデータ。

• verifyHdfsTestContent

  public void verifyHdfsTestContent(java.lang.String expectedResult,
                           java.lang.String pathToHdfsFile)

  hdfs ファイルの内容を結果に対して評価します。等しい場合はアクションは実行されず、そうでない場合はアサートがスローされます。

  パラメーター:

  expectedResult - hdfs ファイル内に存在する必要があるデータ。

  pathToHdfsFile - HDFs ファイルシステム上のファイルの場所