コンストラクターの詳細

• Sources

  public Sources(XdEnvironment xdEnvironment)

  提供された環境を使用して新しい Sources インスタンスを構築します。

  パラメーター:

  xdEnvironment - 接続するポート / ホストに関する情報を含む環境

メソッドの詳細

• http

  public SimpleHttpSource http()

  デフォルトのターゲットホスト (localhost) とデフォルトのポート (9000) を使用して、http ソースのインスタンスを作成します。

  戻り値:

  HttpSource のインスタンス

• http

  public SimpleHttpSource http(java.lang.String host)

  デフォルトのターゲットホストとデフォルトのポート (9000) を使用して http ソースのインスタンスを作成します。

  パラメーター:

  host - http データが投稿されるホスト IP。

  戻り値:

  HttpSource のインスタンス

• http

  public SimpleHttpSource http(java.lang.String host,
                      int port)

  デフォルトのターゲットホストと指定されたポートを使用して、http ソースのインスタンスを作成します。

  パラメーター:

  host - http データが投稿されるホスト IP。

  port - 接続するポート

  戻り値:

  HttpSource のインスタンス

• httpSource

  public SimpleHttpSource httpSource(java.lang.String streamName)

  実行時にストリーム名から解決されたターゲットホストを使用して、http ソースのインスタンスを作成します。

  パラメーター:

  streamName - http ソースモジュールがデプロイされているストリームの名前

  戻り値:

  実行時にデプロイされる http モジュールのホストとポートで構成された HttpSource のインスタンス。

• httpSource

  public SimpleHttpSource httpSource()

  デフォルトのストリーム名から実行時に解決されるターゲットホストを使用して、http ソースのインスタンスを作成します。

  戻り値:

  実行時にデプロイされる http モジュールのホストとポートで構成された HttpSource のインスタンス。

• tcp

  public TcpSource tcp()

  デフォルトのターゲットホスト localhost とポートで新しい TcpSource を構築します (1234)

  戻り値:

  TcpSource のインスタンス

• tcp

  public TcpSource tcp(java.lang.String host)

  環境から取得したデフォルトのターゲットホストとデフォルトのポートを使用して新しい TcpSource を構築します (1234)

  パラメーター:

  host - TCP データが投稿されるホスト IP。

  戻り値:

  TcpSource のインスタンス

• tcp

  public TcpSource tcp(java.lang.String host,
              int port)

  環境から取得したデフォルトのターゲットホストと指定されたポートを使用して、新しい TcpSource を構築します。

  パラメーター:

  host - TCP データが投稿されるホスト IP。

  port - 接続するポート

  戻り値:

  TcpSource のインスタンス

• tcpSource

  public TcpSource tcpSource()

  デフォルトのストリーム名から実行時に解決されたターゲットホストを使用して新しい TcpSource を構築します。

  戻り値:

  実行時にデプロイされる TCP モジュールのホストとポートで構成された TcpSource のインスタンス。

• tcpSource

  public TcpSource tcpSource(java.lang.String streamName)

  実行時にストリーム名から解決されたターゲットホストを使用して新しい TcpSource を構築します。

  パラメーター:

  streamName - TCP ソースモジュールがデプロイされているストリームの名前

  戻り値:

  実行時にデプロイされる http モジュールのホストとポートで構成された TcpSource のインスタンス。

• tail

  public SimpleTailSource tail(int delayInMillis,
                      java.lang.String fileName)

  指定されたファイル名と遅延で新しい SimpleTailSource を構築します

  パラメーター:

  delayInMillis - 見つからないファイルの表示を待たないプラットフォームで、ファイルを検索する頻度 (ミリ秒)。

  fileName - 末尾のファイルの絶対パス

  戻り値:

  尾部源

• jms

  public JmsSource jms()

  環境で指定されたデフォルトの JMS ブローカーホストとポートを使用して新しい JmsSource を構築します

  戻り値:

  JMS ソース

• mqtt

  public MqttSource mqtt()

  環境で指定されているデフォルトの RabbitMQ (MQTT 対応) ブローカーホストを使用して、新しい MqttSource を構築します。

  戻り値:

  MQTT ソース

• file

  public SimpleFileSource file(java.lang.String dir,
                      java.lang.String fileName)

  指定されたディレクトリとファイル名を使用して新しい SimpleFileSource を構築します

  パラメーター:

  dir - ディレクトリ名

  fileName - ファイル名

  戻り値:

  新しい SimpleFileSource

• rabbitSource

  public RabbitSource rabbitSource()

  環境とデフォルトを使用して新しい RabbitSource を構築します。

  戻り値:

  ラビットソースフィクスチャのインスタンス。

• twitterSearch

  public TwitterSearchSource twitterSearch(java.lang.String query)

  提供されたクエリ文字列を検索する TwitterSearchSource を構築します。

  パラメーター:

  query - Twitter で検索する文字列。

  戻り値:

  twitterSearchSource フィクスチャのインスタンス。

• twitterStream

  public TwitterStreamSource twitterStream()

  TwitterStreamSource フィクスチャを構築します。

  戻り値:

  twitterStreamSource フィクスチャのインスタンス。

• syslogTcp

  public SyslogTcpSource syslogTcp(java.lang.String host)

  TCP 経由で syslog イベントを受信する SyslogTcpSource を構築します。

  パラメーター:

  host - シミュレートされた syslog トラフィックが送信されるマシンの IP。

  戻り値:

  SyslogTcpSource のインスタンス。

• syslogTcp

  public SyslogTcpSource syslogTcp()

  TCP 経由で syslog イベントを受信する SyslogTcpSource を構築します。

  戻り値:

  SyslogTcpSource のインスタンス。

• syslogTcpSource

  public SyslogTcpSource syslogTcpSource()

  デフォルトのストリーム名から実行時に解決されたターゲットホストを使用して新しい SyslogTcpSource を構築します。

  戻り値:

  実行時にデプロイされる syslogtcp ソースのホストとポートで構成された SyslogTcpSource のインスタンス。

• syslogUdp

  public SyslogUdpSource syslogUdp(java.lang.String host)

  UDP 経由で syslog イベントを受信する SyslogUdpSource を構築します。

  パラメーター:

  host - シミュレートされた syslog トラフィックが送信されるマシンの IP。

  戻り値:

  SyslogUdpSource のインスタンス。

• syslogUdp

  public SyslogUdpSource syslogUdp()

  デフォルトを使用して UDP 経由で syslog イベントを受信する SyslogUdpSource を構築します。

  戻り値:

  SyslogUdpSource のインスタンス。

• syslogUdpForContainerHost

  public SyslogUdpSource syslogUdpForContainerHost()

  デフォルトのストリーム名から実行時に解決されたターゲットホストを使用して新しい SyslogUdpSource を構築します。

  戻り値:

  実行時にデプロイされる syslogudp ソースのホストとポートで構成された SyslogTcpSource のインスタンス。

• tap

  public Tap tap(java.lang.String streamName)

  タップフィクスチャを構築します。

  パラメーター:

  streamName - タップするストリームの名前

  戻り値:

  フィクスチャをタップ

• gemFireSource

  public GemFireSource gemFireSource(java.lang.String region)

  新しい GemFireSource を構築します。

  パラメーター:

  region - このソースにバインドされた領域の名前

  戻り値:

  GemFireSource の新しいインスタンス。

• gemFireCqSource

  public GemFireCQSource gemFireCqSource(java.lang.String query)

  新しい GemFireCQSource を構築します。

  パラメーター:

  query - このソースにバインドされた OQL クエリ文字列

  戻り値:

  GemFireCQSource の新しいインスタンス。

• kafkaSource

  public KafkaSource kafkaSource()

  新しい KafkaSource を構築します

  戻り値:

  KafkaSource の新しいインスタンス

• tcpClientSource

  public TcpClientSource tcpClientSource()

  新しい TcpClientSource を構築します。

  戻り値:

  TcpClientSource の新しいインスタンス。