コンストラクターの詳細

• GemFireSource

  public GemFireSource(java.lang.String region)

  Gemfire Sink モジュールを作成します。

  パラメーター:

  region - このストリームに使用するリージョンの名前。リージョンはサーバー上に存在している必要があります。

メソッドの詳細

• useLocator

  public GemFireSource useLocator(boolean useLocator)

  サーバーノードではなく Gemfire ロケーターを参照するようにホストとポートを設定します。

  パラメーター:

  useLocator - ロケータを使用する場合は true。デフォルトは false です。

  戻り値:

  this

• host

  public GemFireSource host(java.lang.String host)

  ホスト名の設定

  パラメーター:

  host - ホスト。デフォルトは localhost です

  戻り値:

  this

• port

  public GemFireSource port(int port)

  gemfire サーバーのポートを設定します。デフォルトは 40404 です

  パラメーター:

  port - 港

  戻り値:

  this

• cacheEventExpression

  public GemFireSource cacheEventExpression(java.lang.String cacheEventExpression)

  キャッシュキーを設定します。デフォルトはストリーム名です

  パラメーター:

  cacheEventExpression - ペイロードを評価する SpEL 式

  戻り値:

  this

• toDSL

  protected java.lang.String toDSL()

  クラスからコピーされた説明: AbstractModuleFixture
  ストリーム定義に含めるのに適したモジュールの表現を返します。 例:  file --dir=xxxx --name=yyyy

  次で指定:

  クラス AbstractModuleFixture<GemFireSource> の toDSL