Candidate Finder MapReduce ジョブの使用
-
AdvanceMatchFactory
のインスタンスを、その静的メソッドgetInstance()
を使用して作成します。 -
Candidate Finder ジョブの入力と出力の詳細を指定します。以下の手順に従って、
ProcessType
を指定するCandidateFinderDetail
のインスタンスを作成することによって、これを行います。このインスタンスは、MRProcessType タイプを使用する必要があります。-
インスタンス MRJobConfig で、
hbase_zookeeper_quorum
およびhbase_zookeeper_property_clientPort
の値を設定します。 -
ComplexSearchQuery
のインスタンスを作成することによって、ジョブのクエリを生成します。このインスタンスの中で、次の操作を行います。QueryName
、IndexFieldName
、IndexFieldType
などのプロパティを設定します。Numeric
、Range
、Contains All
、Contains None
などの検索クエリを使用できます。- 検索クエリ プロパティを設定し、
AND
やOR
などの論理演算子を使用してこれらを接続します。
注:ComplexSearchQuery
の各インスタンスは、1 つのインスタンス、子のインスタンスの階層、または論理演算子を使用して結合されネストされたインスタンスを使用して定義できます。列挙 JoinType、および列挙 Operationを参照してください。 -
inputPath
インスタンスのCandidateFinderDetail
フィールドを使用して、入力ファイルの詳細を設定します。- テキスト入力ファイルの場合は、適切なコンストラクタを呼び出して、関連する詳細な入力ファイル情報を指定して
FilePath
のインスタンスを作成します。 - ORC 入力ファイルの場合、ORC 入力ファイルのパスを引数に指定して
OrcFilePath
のインスタンスを作成します。 - PARQUET 入力ファイルの場合、PARQUET 入力ファイルのパスを引数に指定して ParquetFilePath のインスタンスを作成します。
- テキスト入力ファイルの場合は、適切なコンストラクタを呼び出して、関連する詳細な入力ファイル情報を指定して
-
CandidateFinderDetail
インスタンスのoutputPath
フィールドを使用して、出力ファイルの詳細を設定します。- テキスト出力ファイルの場合は、適切なコンストラクタを呼び出して、関連する詳細な出力ファイル情報を指定して
FilePath
のインスタンスを作成します。 - ORC 出力ファイルの場合、ORC 出力ファイルのパスを引数に指定して
OrcFilePath
のインスタンスを作成します。 - PARQUET 出力ファイルの場合、PARQUET 出力ファイルのパスを引数に指定して ParquetFilePath のインスタンスを作成します。
- テキスト出力ファイルの場合は、適切なコンストラクタを呼び出して、関連する詳細な出力ファイル情報を指定して
-
jobName
インスタンスのCandidateFinderDetail
フィールドを使用して、ジョブの名前を設定します。 -
CandidateFinderDetail
インスタンスのFetchBatchSize
フィールドを設定します。デフォルトは 10000 です。 -
CandidateFinderDetail
インスタンスのMaximumResults
フィールドを設定します。デフォルトは 10 です。 -
CandidateFinderDetail
インスタンスのStartingRecord
フィールドを設定します。デフォルトは 1 です。
-
インスタンス MRJobConfig で、
-
MapReduce ジョブを作成するには、先ほど作成した
AdvanceMatchFactory
のインスタンスを使用してそのメソッドcreateJob()
を呼び出します。ここで、上のCandidateFinderDetail
のインスタンスを引数として渡します。createJob()
メソッドはジョブを作成し、List
インスタンスのControlledJob
を返します。 -
JobControl
のインスタンスを使用して、作成したジョブを実行します。 -
MapReduce ジョブの正常実行後にレポート カウンタを表示するには、先ほど作成した
AdvanceMatchFactory
のインスタンスを使用して、そのメソッドgetCounters()
を呼び出します。作成したジョブを引数として渡します。