Apache Spark BatchのtNLPModelプロパティ
これらのプロパティは、Spark Batchジョブのフレームワークで実行されているtNLPModelの設定で使用します。
Spark BatchのtNLPModelコンポーネントは、Natural Language Processingファミリーに属しています。
このフレームワーク内のコンポーネントは、ビッグデータ対応のTalend Platform製品すべて、およびTalend Data Fabricで利用できます。
基本設定
[Define a storage configuration component] (ストレージ設定コンポーネントを定義) |
HDFSなどのターゲットファイルシステムへの接続の設定情報を提供するために使用する設定コンポーネントを選択します。 このチェックボックスをオフにすると、ターゲットファイルシステムはローカルシステムになります。 使用する接続設定は同じジョブ内にあることが必要です。たとえば、tHDFSConfigurationコンポーネントをジョブにドロップした場合は、このコンポーネントを選択して、所定のHDFSシステム内で結果を書き込むことができます。 |
[Schema] (スキーマ)と[Edit Schema] (スキーマを編集) |
スキーマとは行の説明のことです。処理して次のコンポーネントに渡すフィールド(カラム)数を定義します。Sparkジョブを作成する場合、フィールドの命名時は予約語のlineを避けます。 ジョブで接続している先行コンポーネントからスキーマを取得するためには、[Sync columns] (カラムを同期)をクリックします。 スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。現在のスキーマがリポジトリータイプの場合は、3つのオプションを利用できます。
入力スキーマの最初のカラムは[token] (トークン)、最後のカラムは[label] (ラベル)である必要があります。 その間に、機能用のカラムを挿入できます。 |
|
[Built-in] (組み込み): そのコンポーネントに対してのみスキーマを作成し、ローカルに保管します。 |
|
[Repository] (リポジトリー): スキーマは作成済みで、リポジトリーに保管されています。さまざまなプロジェクトやジョブデザインで再利用できます。 |
[Feature template] (機能テンプレート) |
[Features] (機能): 生成する挿入トークンレベルの機能をリストから選択します。
[Relative position] (相対位置): 機能の相対位置の構成です。コンマで区切られた数字の列にします。
たとえば-2,-1,0,1,2の場合は、機能として現在のトークンと前後2つずつのコンテキストトークンを使用するという意味になります。 |
[Additional Features] (追加機能) |
[Additional feature template] (追加機能のテンプレート)に機能を追加するには、このチェックボックスをオンにします。 |
[NLP Library] (NLPライブラリー) |
このリストから、ScalaNLPとStanford CoreNLPの間で使用するライブラリーを選択します。 入力が、tNLPPreprocessingコンポーネントを使用して前処理したテキストである場合は、前処理に使用したのと同じNLP Libraryを選択します。 |
[Model location] (モデルのロケーション) |
[Save the model on file system] (モデルをファイルシステムに保存)チェックボックスをオンにし、次のいずれかを行います。
特定のファイルシステム(S3またはHDFSなど)にモデルを保存する場合は、ジョブで対応するコンポーネントを使用し、コンポーネントの基本設定で[Define a storage configuration component] (ストレージ設定コンポーネントの定義)チェックボックスをオンにする必要があります。 参照用のボタンはSpark Localモードでは機能しません。お使いのディストリビューションでStudioがサポートしているその他のSpark Yarnモードを使用している場合は、同じジョブ内の設定コンポーネント(tHDFSConfigurationなど)で接続を正しく設定したことを確認する必要があります。使用されるファイルシステムに応じて設定コンポーネントを使用します。 |
[Run cross validation evaluation] (クロス検証評価の実行) |
このチェックボックスをオンにすると、tNLPModelはKフォールドクロス検証を実行してモデルのパフォーマンスを評価し、モデルを生成します。 デフォルトでは、[Fold] (フォールド)パラメーターは3に設定されています。
モデルの改善ごとに[Run] (実行)ビュー内のクロス検証評価から生じる最適加重のF1スコアを出力するために、[Run] (実行)ビューの[Advanced Settings] (詳細設定)タブで、log4jLevelを[Info] (情報)に設定します。 |
使用方法
使用ルール |
このコンポーネントは、終了コンポーネントとして使用され、入力リンクを必要とします。 このコンポーネントは、所属するSpark Batchのコンポーネントのパレットと共に、Spark Batchジョブを作成している場合にだけ表示されます。 |
[Cross validation evaluation] (クロス検証評価) |
次のアイテムが[Run] (実行)ビューのコンソールに出力されます。
モデルの改善ごとに、最適加重のF1スコアが[Run] (実行)ビューのコンソールに出力されます。このスコアは、Log4j INFOレベルの他の情報と共に出力されます。 log4jロギングレベルの詳細は、http://logging.apache.org/log4j/1.2/apidocs/org/apache/log4j/Level.htmlのApacheのドキュメントを参照してください。 |
[Spark Batch Connection] (Spark Batch接続) |
[Run] (実行)ビューの[Spark configuration] (Spark設定)タブで、ジョブ全体でのSparkクラスターへの接続を定義します。また、ジョブでは、依存jarファイルを実行することを想定しているため、Sparkがこれらのjarファイルにアクセスできるように、これらのファイルの転送先にするファイルシステム内のディレクトリーを指定する必要があります。
この接続は、ジョブごとに有効になります。 |