Apache Spark StreamingのtBigQueryConfigurationプロパティ

これらのプロパティは、Spark Streamingジョブのフレームワークで実行されているtBigQueryConfigurationを設定するために使われます。

Spark StreamingのtBigQueryConfigurationコンポーネントは、ストレージファミリーとデータベースファミリーに属しています。

このコンポーネントはTalend Real-Time Big Data PlatformとTalend Data Fabricで利用できます。

基本設定

このコンポーネントをGoogle Dataprocと併用する場合:

BigQuery一時GCSパス	Google BigQueryで使用するデータを一時的に保管するには、Google Storageにディレクトリーを入力します。ディレクトリーがない場合はただちに作成されますが、このディレクトリーを含むバケットはあらかじめ存在している必要があります。ディレクトリーの構文はgs://my_bucket/my_directoryにする必要があります。 Google Cloud PlatformでGoogle BigQueryをDataprocで使用する場合は、Dataprocクラスターの実行と同じ領域をBigQueryデータセットとして選択します。
[Location] (ロケーション)	データの読み取りまたは書き込みを行うGoogle複数地域ロケーションを1つ選択します。リソースデータセットとターゲットデータセットは、同じ場所になければなりません。 Sparkジョブでは、米国とEUのロケーションのみがサポートされています。 Googleロケーションとそのロケーションを適切に使用する方法の詳細は、 Google CloudのドキュメンテーションでDataset Locationsをご覧ください。

BigQuery一時GCSパス

Google BigQueryで使用するデータを一時的に保管するには、Google Storageにディレクトリーを入力します。ディレクトリーがない場合はただちに作成されますが、このディレクトリーを含むバケットはあらかじめ存在している必要があります。ディレクトリーの構文はgs://my_bucket/my_directoryにする必要があります。

Google Cloud PlatformでGoogle BigQueryをDataprocで使用する場合は、Dataprocクラスターの実行と同じ領域をBigQueryデータセットとして選択します。

[Location] (ロケーション)

データの読み取りまたは書き込みを行うGoogle複数地域ロケーションを1つ選択します。リソースデータセットとターゲットデータセットは、同じ場所になければなりません。

Sparkジョブでは、米国とEUのロケーションのみがサポートされています。

Googleロケーションとそのロケーションを適切に使用する方法の詳細は、 Google CloudのドキュメンテーションでDataset Locationsをご覧ください。

このコンポーネントをその他のディストリビューションと併用する場合

[Project ID] (プロジェクトID)	Google Cloud PlatformプロジェクトのIDを入力します。プロジェクトIDがわからない場合は、Google Cloud Platformサービスの[Manage Resources]ページでご確認ください。
[Path to Google Credentials file] (Googleクレデンシャルファイルへのパス)	使用するユーザーアカウントに関連付けられている認証情報ファイルのパスを入力します。このファイルはTalendジョブが実際に起動および実行されるコンピューターに保管されている必要があります。 Talend JobServerを使用してジョブを実行する場合、ジョブを起動するTalend JobServerのマシンだけでなく、ジョブを実行するSparkクラスターのワーカーマシンにも認証情報ファイルを保管します。Talend JobServerを使用しない場合は、ジョブを起動するローカルマシンとSparkクラスターのワーカーマシンに認証情報ファイルを保管します。
[Use P12 credentials file format] (P12認証情報ファイル形式を使用)	使用するGoogleクレデンシャルファイルがP12形式の場合は、このチェックボックスをオンにし、表示される[Service account Id] (サービスアカウントID)フィールドにP12認証情報ファイルが作成されたサービスアカウントのIDを入力します。
BigQuery一時GCSパス	Google BigQueryで使用するデータを一時的に保管するには、Google Storageにディレクトリーを入力します。ディレクトリーがない場合はただちに作成されますが、このディレクトリーを含むバケットはあらかじめ存在している必要があります。ディレクトリーの構文はgs://my_bucket/my_directoryにする必要があります。 Google Cloud PlatformでGoogle BigQueryをDataprocで使用する場合は、Dataprocクラスターの実行と同じ領域をBigQueryデータセットとして選択します。
[Location] (ロケーション)	データの読み取りまたは書き込みを行うGoogle複数地域ロケーションを1つ選択します。リソースデータセットとターゲットデータセットは、同じ場所になければなりません。 Sparkジョブでは、米国とEUのロケーションのみがサポートされています。 Googleロケーションとそのロケーションを適切に使用する方法の詳細は、 Google CloudのドキュメンテーションでDataset Locationsをご覧ください。

使用方法

使用ルール	このコンポーネントは、サブジョブでスタンドアロンとして使い、ジョブ全体のGoogle BigQueryとGoogleストレージへの接続設定を提供します。
[Spark Connection] (Spark接続)	[Run] (実行)ビューの[Spark configuration] (Spark設定)タブで、ジョブ全体でのSparkクラスターへの接続を定義します。また、ジョブでは、依存jarファイルを実行することを想定しているため、Sparkがこれらのjarファイルにアクセスできるように、これらのファイルの転送先にするファイルシステム内のディレクトリーを指定する必要があります。 Yarnモード(YarnクライアントまたはYarnクラスター): Google Dataprocを使用している場合、[Spark configuration] (Spark設定)タブの[Google Storage staging bucket] (Google Storageステージングバケット)フィールドにバケットを指定します。 HDInsightを使用している場合、[Spark configuration] (Spark設定)タブの[Windows Azure Storage configuration] (Windows Azure Storage設定)エリアでジョブのデプロイメントに使用するブロブを指定します。 Altusを使用する場合は、[Spark configuration] (Spark設定)タブでジョブのデプロイにS3バケットまたはAzure Data Lake Storageを指定します。オンプレミスのディストリビューションを使用する場合は、クラスターで使われているファイルシステムに対応する設定コンポーネントを使用します。一般的に、このシステムはHDFSになるため、tHDFSConfigurationを使用します。 [Standalone mode] (スタンドアロンモード): クラスターで使われているファイルシステム(tHDFSConfiguration Apache Spark BatchやtS3Configuration Apache Spark Batchなど)に対応する設定コンポーネントを使用します。ジョブ内に設定コンポーネントがない状態でDatabricksを使用している場合、ビジネスデータはDBFS (Databricks Filesystem)に直接書き込まれます。この接続は、ジョブごとに有効になります。

使用ルール

このコンポーネントは、サブジョブでスタンドアロンとして使い、ジョブ全体のGoogle BigQueryとGoogleストレージへの接続設定を提供します。

[Spark Connection] (Spark接続)

[Run] (実行)ビューの[Spark configuration] (Spark設定)タブで、ジョブ全体でのSparkクラスターへの接続を定義します。また、ジョブでは、依存jarファイルを実行することを想定しているため、Sparkがこれらのjarファイルにアクセスできるように、これらのファイルの転送先にするファイルシステム内のディレクトリーを指定する必要があります。

Yarnモード(YarnクライアントまたはYarnクラスター):
- Google Dataprocを使用している場合、[Spark configuration] (Spark設定)タブの[Google Storage staging bucket] (Google Storageステージングバケット)フィールドにバケットを指定します。
- HDInsightを使用している場合、[Spark configuration] (Spark設定)タブの[Windows Azure Storage configuration] (Windows Azure Storage設定)エリアでジョブのデプロイメントに使用するブロブを指定します。
- Altusを使用する場合は、[Spark configuration] (Spark設定)タブでジョブのデプロイにS3バケットまたはAzure Data Lake Storageを指定します。
- オンプレミスのディストリビューションを使用する場合は、クラスターで使われているファイルシステムに対応する設定コンポーネントを使用します。一般的に、このシステムはHDFSになるため、tHDFSConfigurationを使用します。
[Standalone mode] (スタンドアロンモード): クラスターで使われているファイルシステム(tHDFSConfiguration Apache Spark BatchやtS3Configuration Apache Spark Batchなど)に対応する設定コンポーネントを使用します。

ジョブ内に設定コンポーネントがない状態でDatabricksを使用している場合、ビジネスデータはDBFS (Databricks Filesystem)に直接書き込まれます。

この接続は、ジョブごとに有効になります。

このページは役に立ちましたか?

このページまたはコンテンツに、タイポ、ステップの省略、技術的エラーなどの問題が見つかった場合は、お知らせください。改善に役立たせていただきます。

こちらにフィードバックをお寄せください