tMapRDBInputの標準プロパティ
これらのプロパティは、標準ジョブのフレームワークで実行されているtMapRDBInputを設定するために使われます。
標準のtMapRDBInputコンポーネントは、ビッグデータファミリーとデータベースNoSQLファミリーに属しています。
このフレームワークのコンポーネントは、すべてのビッグデータ対応のTalend製品およびTalend Data Fabricで使用できます。
基本設定
[Property type] (プロパティタイプ) |
[Built-in] (組み込み)と[Repository] (リポジトリー)のいずれかです。 [Built-In] (組み込み): 一元的に保存されるプロパティデータはありません。 [Repository] (リポジトリー): プロパティが保存されているリポジトリーファイルを選択します。 プロパティは、リポジトリーツリーのHadoopクラスターノードに一元的に保存されます。 |
[Use an existing connection] (既存の接続を使用) |
定義済みの接続の詳細を再利用する場合は、このチェックボックスを選択して、[Component List] (コンポーネントリスト)ドロップダウンリストから、目的の接続コンポーネントを選択します。 |
[Hadoop version of the distribution] (ディストリビューションのHadoopバージョン) |
Talend Studioによってまだ正式にサポートされていないクラスターへの接続用に、ディストリビューションリストから[Custom] (カスタム)を選択した場合にしか、このリストは表示されません。その場合、このカスタムクラスターのHadoopバージョン、つまりHadoop 1またはHadoop 2を選択する必要があります。 |
[Zookeeper quorum] (Zookeeperクォーラム) |
Talend Studioとデータベース間のトランザクションを調整するZooKeeperサービスの名前またはURLを入力します。ZooKeeperを設定する時に、zookeeper.znode.parentプロパティを明示的に設定して、データベースで作成および使用されているZnodeがすべて含まれているルートZnodeへのパスを定義し、[Set Zookeeper znode parent] (親Zookeeper znodeを設定)チェックボックスをオンにしてこのプロパティを定義しなければならない場合があります。 |
[Zookeeper client port] (Zookeeperクライアントポート) |
使用しているZooKeeperサービスのクライアントリスニングポートの数を指定します。 |
[Use Kerberos authentication] (Kerberos認証を使用) |
使用するデータベースでKerberosセキュリティが実行される場合は、このチェックボックスを選択し、[HBase Master principal] (Hbaseマスタープリンシパル)フィールドと[HBase Region Server principal] (HBaseリージョンサーバープリンシパル)フィールドにプリンシパル名を入力します。この情報は、使用するクラスターのhbase-site.xmlファイルの中にあります。 ログインにKerberosのkeytabファイルが必要な場合は、[Use a keytab to authenticate] (認証にkeytabを使用)チェックボックスをオンにします。keytabファイルには、Kerberosのプリンシパルと暗号化されたキーのペアが含まれています。使用するプリンシパルを[Principal] (プリンシパル)フィールドに入力し、keytabファイルへのアクセスパスを[Keytab] フィールドに入力します。このキータブファイルは、ジョブが実際に実行されているマシン(Talend JobServerなど)に保存する必要があります。 keytabが有効なジョブは、プリンシパルに任命されたユーザーでなくても実行できますが、使用するkeytabファイルの読み取り権限が必要です。たとえばuser1というユーザー名でジョブを実行し、使用するプリンシパルがguestの場合、user1に使用するキータブファイルの読み取り権限があることをご確認ください。 |
[Schema] (スキーマ)と[Edit schema] (スキーマを編集) |
スキーマとは行の説明のことです。処理して次のコンポーネントに渡すフィールド(カラム)数を定義します。Sparkジョブを作成する場合、フィールドの命名時は予約語のlineを避けます。 スキーマを変更するには[Edit schema] (スキーマを編集)をクリックします。現在のスキーマがリポジトリータイプの場合は、3つのオプションを利用できます。
|
|
[Built-in] (組み込み): そのコンポーネントに対してのみスキーマを作成し、ローカルに保管します。 |
|
[Repository] (リポジトリー): スキーマは作成済みで、リポジトリーに保管されています。さまざまなプロジェクトやジョブデザインで再利用できます。 |
テーブルネームスペースマッピングの設定 |
Apache HBaseテーブルとMapRテーブルの間のマッピングを構成するために使用する文字列を入力します。 使用できる有効な構文については、http://doc.mapr.com/display/MapR40x/Mapping+Table+Namespace+Between+Apache+HBase+Tables+and+MapR+Tablesをご覧ください。 |
[Table name] (テーブル名) |
カラムを抽出するテーブルの名前を入力します。 |
[Define a row selection] (行選択を定義) |
このチェックボックスを選択して、[Start row] (開始行)フィールドと[End row] (終了行)フィールドに対応する行キーを入力し、現在のコンポーネントで抽出する行範囲を指定します。 [Is by filter] (フィルターによる)を使用して設定するフィルターでは、使用するレコードをフィルタリングする前にすべてのレコードをロードする必要があるのに対して、この機能では使用する行のみを直接選択できます。 |
[Mapping] (マッピング) |
このテーブルに入力して、処理するデータフロー用に定義されているスキーマカラムに使うテーブルのカラムをマップします。 |
詳細設定
[tStatCatcher Statistics] (tStatCatcher統計) |
このチェックボックスをオンにすると、コンポーネントレベルでログデータを収集できます。 |
[Properties] (プロパティ) |
データベースにカスタム設定を使用する必要がある場合は、カスタマイズするプロパティをこのテーブルで設定します。カスタマイズされたプロパティは、実行時にTalend Studioによって使用される対応プロパティを上書きします。 たとえば、データベースの設定で、dfs.replicationプロパティの値を1に定義する必要があります。次に、プラスボタンを使用してこのテーブルに1行を追加し、このプロパティの名前と値をこの行に入力する必要があります。 情報メモ注:
[Basic settings] (基本設定)ビューで[Using an existing connection] (既存の接続を使用)チェックボックスをオンにして既存の接続を使用している場合、このテーブルは使用できません。 |
Is by filter (フィルターによる) |
このチェックボックスを選択して、フィルターを使用して、正規表現をベースとするキーまたは値の選択など、データベースからきめ細かいデータ選択を行います。 選択すると、フィルタリング条件の定義に使用する[Filter] (フィルター)テーブルが利用できるようになります。 この機能はHBaseから提供されているフィルターを利用しており、Apache HBaseのドキュメンテーションで説明されている制約を受けます。したがって、これらのフィルターをフルに活用するには、HBaseに関する高度な知識が必要です。 |
Logical operation (論理演算) |
フィルター間の論理関係を定義するために使用する必要のあるオペレーターを選択します。使用可能なオペレーターは次のとおりです。
|
[Filter] (フィルター) |
このテーブルの下にあるボタンをクリックし、必要な行数を追加します。各行は1つのフィルターを表しています。フィルターに設定する必要のあるパラメーターは、次のとおりです。
|
グローバル変数
グローバル変数 |
NB_LINE: 入力コンポーネントによって読み取られた行の数、または出力コンポーネントに転送された行の数。これはAfter変数で、整数を返します。 ERROR_MESSAGE: エラーが発生した時にコンポーネントによって生成されるエラーメッセージ。これはAfter変数で、文字列を返します。この変数はコンポーネントにこのチェックボックスが存在し、[Die on error] (エラー発生時に強制終了)がオフになっている場合のみ機能します。 Flow変数はのコンポーネントの実行中に機能し、After変数はコンポーネントの実行後に機能します。 フィールドまたは式に変数を入力する場合は、Ctrl + スペースを押して変数リストにアクセスし、使用する変数を選択します。 変数の詳細は、コンテキストと変数を使用をご覧ください。 |
使用方法
使用ルール |
このコンポーネントは、通常、ジョブの開始コンポーネントとして使用され、常に出力リンクが必要です。 |
前提条件 |
始める前に、データベースで想定されているループバックIPの前提条件を満たしていることをご確認ください。 Talend Studio との操作を確実に行うには、Hadoopディストリビューションを適切にインストールする必要があります。以下のリストに、MapR関連の情報などを示します。
Hadoopディストリビューションのインストール方法の詳細は、使用しているHadoopディストリビューションに対応するマニュアルをご覧ください。 |