コンストラクターの詳細

• GemFireCQSource

  public GemFireCQSource(java.lang.String query)

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

  パラメーター:

  query - OQL クエリ文字列。

メソッドの詳細

• useLocator

  public GemFireCQSource useLocator(boolean useLocator)

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

  パラメーター:

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

  戻り値:

  this

• host

  public GemFireCQSource host(java.lang.String host)

  ホスト名の設定

  パラメーター:

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

  戻り値:

  this

• port

  public GemFireCQSource port(int port)

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

  パラメーター:

  port - 港

  戻り値:

  this

• toDSL

  protected java.lang.String toDSL()

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

  次で指定:

  クラス AbstractModuleFixture<GemFireCQSource> の toDSL