Apache Spark StreamingのtElasticSearchConfigurationプロパティ
これらのプロパティは、Spark Streamingジョブのフレームワークで実行されているtElasticSearchConfigurationを設定するために使われます。
Spark StreamingのtElasticSearchConfigurationコンポーネントは、ElasticSearchファミリーに属しています。
このコンポーネントは、Talend Real Time Big Data PlatformおよびTalend Data Fabricで利用できます。
基本設定
[Nodes] (ノード) |
使用するElasticsearchシステムをホストしているクラスターのロケーションを入力します。 [Nodes] (ノード)パラメーターは必須で、ElasticSearchに接続するElasticSearchコンポーネントがElasticSearchノードクライアントを使う場合のみ最終的に考慮に入れられます。すなわち、tElasticSearchInputコンポーネントとtElasticSearchOutputコンポーネントです。 ElasticSearchノードクライアントとElasticSearchトランスポートクライアントについては、https://www.elastic.co/guide/en/elasticsearch/guide/current/_transport_client_versus_node_client.html (英語のみ)をご覧ください。 |
[Transport addresses] (住所の転送) |
コンポーネントを接続する必要のあるElasticSearchノードのアドレスを入力します。 このパラメーターは、ElasticSearchジョブ(正確にはジョブ内のtElasticSearchLookupInput)が、使用するElasticSearchクラスターに接続するためにElasticSearchトランスポートクライアントを使う際に必要です。ElasticSearchトランスポートクライアントを使わない場合は、このフィールドの空の二重引用符("")をそのままにしておきます。 ElasticSearchノードクライアントとElasticSearchトランスポートクライアントについては、https://www.elastic.co/guide/en/elasticsearch/guide/current/_transport_client_versus_node_client.html (英語のみ)をご覧ください。 |
[Cluster name] (クラスター名) |
使用するElasticSearchクラスターの名前を入力します。 このパラメーターは、ElasticSearchジョブ(正確にはジョブ内のtElasticSearchLookupInput)が、使用するElasticSearchクラスターに接続するためにElasticSearchトランスポートクライアントを使う際に必要です。ElasticSearchトランスポートクライアントを使わない場合は、このフィールドの空の二重引用符("")をそのままにしておきます。 |
SSL/TLSの使用 |
SSLまたはTLS暗号化接続を有効にする場合は、このチェックボックスを選択します。 次に、同じジョブ内のtSetKeyStoreコンポーネントを使用して暗号化情報を指定する必要があります。 |
[User authentication] (ユーザー認証) |
使用するElasticSearchシステムで認証情報が必要な場合は、このチェックボックスをオンにして、認証情報を入力します。 パスワードを入力するには、パスワードフィールドの横にある[...]ボタンをクリックし、ポップアップダイアログボックスにパスワードを二重引用符の間に入力し、OKをクリックして設定を保存します。 |
設定 |
アクションをさらにカスタマイズするには、Elasticsearchで受け入れられているパラメーターを追加します。 たとえば、es.mapping.idを[Key] (キー)カラムに、trueを[Value] (値)カラムに入力して、ドキュメントのフィールド/プロパティ名がドキュメントIDを含むようにします。入力する情報は二重引用符で囲む必要があります。 使えるパラメーターのリストは、https://www.elastic.co/guide/en/elasticsearch/hadoop/master/configuration.html (英語のみ)をご覧ください。 |
詳細設定
[Connection pool] (接続プール) |
このエリアでは、各Sparkエグゼキューターに、同時に開いたままにする接続の数を制御するための接続プールを設定するために使われます。以下の接続プールパラメーターに与えられているデフォルト値は、ほとんどのユースケースでそのまま利用できます。
|
[Evict connections] (接続を無効化) |
接続プール内の接続を破棄する条件を定義する場合は、このチェックボックスを選択します。オンにすると、以下のフィールドが表示されます。
|
使用方法
使用ルール |
このコンポーネントは、他のコンポーネントに接続せずに使用されます。 設定がランタイムにジョブ全体で使われるように、tElasticSearchConfigurationと共に、実行するElasticSearch関連のサブジョブを同じジョブにドロップします。
このコンポーネントは、所属するSpark Streamingのコンポーネントのパレットと共に、Spark Streamingジョブを作成している場合にだけ表示されます。 特に明記していない限り、このドキュメントのシナリオでは、標準ジョブ、つまり従来の Talend データ統合ジョブだけを扱います。 |
[Spark Connection] (Spark接続) |
[Run] (実行)ビューの[Spark configuration] (Spark設定)タブで、ジョブ全体でのSparkクラスターへの接続を定義します。また、ジョブでは、依存jarファイルを実行することを想定しているため、Sparkがこれらのjarファイルにアクセスできるように、これらのファイルの転送先にするファイルシステム内のディレクトリーを指定する必要があります。
この接続は、ジョブごとに有効になります。 |