HDFS (Hadoop) コネクタリファレンス - Mule 4

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

この設定に指定する接続型。

x

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。これは、インスタンスが有効期限の対象となった瞬間にプラットフォームでそのインスタンスが期限切れになるということではありません。必要に応じて、インスタンスがパージされます。

String (文字列)

Kerberos プリンシパル。ユーザー名は、​hadoop.job.ugi​ 設定エントリとして HDFS クライアントに渡されます。ユーザー名は、​[Configuration Resources (設定リソース)]​ および ​[Configuration Entries (設定エントリ)]​ で指定した値で上書きできます。このパラメーターは、後方互換性を確保するために [Username (ユーザー名)] と呼ばれます。

String (文字列)

指定したユーザー名に関連付けられた keytab ファイル​へのパスを入力します。このパスを使用して、認証サーバーからチケット保証チケット (TGT) を取得します。この値を指定しない場合、Kerberos によってローカルの Kerberos キャッシュ内で指定のユーザー名に関連付けられた TGT が検索されます。

String (文字列)

接続先のファイルシステムの名前。ネームノードは、​FileSystem#FS_DEFAULT_NAME_KEY​ 設定のエントリとして HDFS クライアントに渡されます。ネームノードは、​[Configuration Resources (設定リソース)]​ および ​[Configuration Entries (設定エントリ)]​ で指定した値で上書きできます。

x

Array of String (文字列の配列)

HDFS クライアントが読み込む設定リソースファイルの ​java.util.List​。追加の設定ファイル (​core-site.xml​ など) を提供できます。

Object (オブジェクト)

HDFS クライアントが使用する設定エントリの ​java.util.Map​。追加の設定エントリをキー-値のペアとして提供できます。

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。再接続が有効になっている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。

String (文字列)

Hadoop が HDFS 内の権限で使用するユーザー ID。簡易認証を使用する場合、Hadoop では、ユーザーを ​HADOOP_USER_NAME​ というシステムプロパティとして設定する必要があります。値が指定されていない場合、Hadoop は現在ログインしている OS ユーザーのユーザー名を使用します。

String (文字列)

接続するファイルシステムの名前。ネームノードは、​FileSystem#FS_DEFAULT_NAME_KEY​ 設定のエントリとして HDFS クライアントに渡されます。ネームノードは、​[Configuration Resources (設定リソース)]​ および ​[Configuration Entries (設定エントリ)]​ で指定した値で上書きできます。

x

Array of String (文字列の配列)

HDFS クライアントが読み込む設定リソースファイルの ​java.util.List​。追加の設定ファイル (​core-site.xml​ など) を提供できます。

Object (オブジェクト)

HDFS クライアントが使用する設定エントリの ​java.util.Map​。追加の設定エントリをキー-値のペアとして提供できます。

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。再接続が有効になっている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。

Boolean (ブール)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。

使用する再接続戦略。

Number (数値)

再接続する頻度 (ミリ秒)。

Number (数値)

再接続の試行回数。

Boolean (ブール)

false の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

true

Number (数値)

再接続する頻度 (ミリ秒)。

Boolean (ブール)

false の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

true

Number (数値)

有効期限の対象とみなされるまで、動的設定インスタンスがアイドル状態を維持できる最大時間のスカラー時間値。

Enumeration (列挙)。次のいずれかになります。

maxIdleTime 属性の時間単位

Number (数値)

ストリームをコンシュームし、ストリームへのランダムアクセスを提供する目的で割り当てられるメモリの容量。ストリームに含まれているデータがこのバッファに適合できる量を超えている場合、bufferSizeIncrement 属性に従ってバッファが拡張され、上限は maxInMemorySize となります。

Number (数値)

バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を 0 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。

Number (数値)

使用するメモリの最大量。これを超えると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。0 以下の値は無制限を意味します。

Enumeration (列挙)。次のいずれかになります。

これらのすべての属性の単位

Number (数値)

データをメモリ内に保持するためにストリームで使用する最大メモリを定義します。これ以上のメモリ量がコンシュームされる場合、ディスク上のコンテンツがバッファされます。

Enumeration (列挙)。次のいずれかになります。

maxInMemorySize で表される単位。

Number (数値)

処理失敗メッセージをトリガーするまでに、メッセージを再配信して処理を失敗できる最大回数。

Boolean (ブール)

再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用するかどうか。

String (文字列)

使用するセキュアハッシュアルゴリズム。設定しない場合、デフォルトの SHA-256 になります。

String (文字列)

メッセージがいつ再配信されたのかを判断するために使用する 1 つ以上の式を定義します。このプロパティは、​[Use Secure Hash (セキュアハッシュを使用)]​ が false の場合にのみ設定できます。

オブジェクトストア

各メッセージの再配信カウンターが保存されるオブジェクトストア。

Check Summary (確認の概要)

Content Summary (コンテンツの概要)

File Status (ファイルの状況)

Boolean (ブール)

Number (数値)

Number (数値)

String (文字列)

Number (数値)

Number (数値)

Number (数値)

Number (数値)

Number (数値)

Number (数値)

Number (数値)

Number (数値)

ファイルのアクセス時間 (ミリ秒)。

Number (数値)

ファイルの複製係数。

Number (数値)

ファイルのブロックサイズ。

Boolean (ブール)

パスがディレクトリであるかどうかを示します。

String (文字列)

ファイルに関連付けられたグループのオーナー。

Number (数値)

ファイルの長さ (バイト)。

Number (数値)

ファイルの変更時間 (ミリ秒)。

String (文字列)

ファイルのオーナー。

String (文字列)

パス名。

String (文字列)

8 進形式の文字列としてのファイルの権限。

Boolean (ブール)

パスがシンボリックリンクであるかどうかを示します。