次の方法で共有

CepStream(TPayload) クラス

  • [アーティクル]

ユーザーが指定したペイロードの種類のイベントのストリームを表します。

継承階層

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream<(Of <(<'TPayload>)>)>

名前空間:  Microsoft.ComplexEventProcessing.Linq
アセンブリ:  Microsoft.ComplexEventProcessing (Microsoft.ComplexEventProcessing.dll)

構文

public sealed class CepStream<TPayload>

型パラメーター

  • TPayload
    ストリームにおけるイベントのペイロードの種類。

CepStream<(Of <(<'TPayload>)>)> 型は、以下のメンバーを公開しています。

メソッド

  名前 説明
パブリック メソッド静的メンバー Create(String) "TPayload" という種類のイベント ペイロードを持つバインド解除ストリームを作成します。
パブリック メソッド静的メンバー Create(Uri, EventShape) 指定した、パブリッシュされたストリームから、入力に対してバインド ストリームを作成します。
パブリック メソッド静的メンバー Create(Uri, EventShape, AdvanceTimeSettings) パブリッシュされた特定のストリームからの入力に対してバインド ストリームを作成します。
パブリック メソッド静的メンバー Create(Application, Uri, EventShape) パブリッシュされた特定のストリームからの入力に対してバインド ストリームを作成します。
パブリック メソッド静的メンバー Create(String, Type, Object, EventShape) 指定した入力アダプター ファクトリからバインド ストリームを作成します。
パブリック メソッド静的メンバー Create(Application, Uri, EventShape, AdvanceTimeSettings) パブリッシュされた特定のストリームからの入力に対してバインド ストリームを作成します。
パブリック メソッド静的メンバー Create(String, Type, Object, EventShape, AdvanceTimeSettings) 指定した入力アダプター ファクトリからバインド ストリームを作成します。
パブリック メソッド静的メンバー Create(Application, String, Type, Object, EventShape) 指定した入力アダプター ファクトリからバインド ストリームを作成します。
パブリック メソッド静的メンバー Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings) 指定した入力アダプター ファクトリからバインド ストリームを作成します。
パブリック メソッド Equals (Object から継承されています。)
パブリック メソッド ExtractInputStreams 指定したストリーム定義から、入力ストリームに関する情報が含まれる一覧を取得します。
プロテクト メソッド Finalize (Object から継承されています。)
パブリック メソッド GetHashCode (Object から継承されています。)
パブリック メソッド GetType (Object から継承されています。)
プロテクト メソッド MemberwiseClone (Object から継承されています。)
パブリック メソッド ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder) 明示的に名前を付けた、パブリッシュされたストリームに出力がバインドされたクエリを作成します。クエリの出力は、動的なクエリ構成で使用できます。パブリッシュされたストリームのイベントを生成できるクエリは、常に 1 つだけです。
パブリック メソッド ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder) 明示的に名前を付けた、パブリッシュされたストリームに出力がバインドされたクエリを作成します。クエリの出力は、動的なクエリ構成で使用できます。パブリッシュされたストリームのイベントを生成できるクエリは、常に 1 つだけです。
パブリック メソッド ToQuery(String, String, EventShape, StreamEventOrder) バインド解除された出力を含むクエリをストリームから作成します。クエリに対するすべての入力は、アダプター、シーケンス、またはその他のクエリにバインドされている必要があります。クエリの出力は、動的なクエリ構成のみで使用できます。このクエリを実行するアプリケーションは、ストリームの定義によって暗黙的に実行されます。
パブリック メソッド ToQuery(Application, String, String, EventShape, StreamEventOrder) 指定したアプリケーションで実行している、バインド解除された出力を含むクエリをストリームから作成します。クエリに対するすべての入力は、アダプター、シーケンス、またはその他のクエリにバインドされていなければなりません。クエリの出力は、動的なクエリ構成のみで使用できます。
パブリック メソッド ToQuery(String, String, Type, Object, EventShape, StreamEventOrder) 出力アダプターにバインドされたストリームからクエリを作成します。出力アダプターは、アダプター ファクトリの種類および構成オブジェクトによって指定されます。このクエリを実行するアプリケーションは、ストリームの定義によって暗黙的に実行されます。
パブリック メソッド ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean) 出力アダプターにバインドされたストリームからクエリを作成します。出力アダプターは、アダプター ファクトリの種類および構成オブジェクトによって指定されます。このクエリを実行するアプリケーションは、ストリームの定義によって暗黙的に実行されます。したがって、クエリは回復性を持つように指定できます。
パブリック メソッド ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder) 指定したアプリケーションで実行している、出力アダプターにバインドされたストリームからクエリを作成します。出力アダプターは、アダプター ファクトリの種類および構成オブジェクトによって指定されます。
パブリック メソッド ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean) 指定したアプリケーションで実行している、出力アダプターにバインドされたストリームからクエリを作成します。出力アダプターは、アダプター ファクトリの種類および構成オブジェクトによって指定されます。したがって、クエリは回復性を持つように指定できます。
パブリック メソッド ToString (Object から継承されています。)

Top

拡張メソッド

  名前 説明
パブリック拡張メソッド AlterEventDuration< (Of < <' (TPayload> ) > > ) 入力イベントの実行時間を変更します。このメソッドでは、イベントの開始時刻は変更されません。 (CepStream によって定義されています。)
パブリック拡張メソッド AlterEventLifetime< (Of < <' (TPayload> ) > > ) ストリーム内のイベントの有効期間を変更します。このメソッドでは、イベントの開始時刻と終了時刻の両方を変更できます。 (CepStream によって定義されています。)
パブリック拡張メソッド ClipEventDuration< (Of < <' (TSource, TClip> ) > > ) sourceStream 内のイベントの有効期間を、matchExpression と一致する clipStream 内にある次の対応するイベントの開始時刻に短縮します。 (CepStream によって定義されています。)
パブリック拡張メソッド CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32) オーバーロードされます。 指定した数の一意のイベント開始時刻に基づいて、既定の出力ポリシーを使用して入力ストリームのイベントをイベントのウィンドウにグループ化します。異なる時刻に開始される新しいイベントが到着すると、ウィンドウはスライドします。 (CepStream によって定義されています。)
パブリック拡張メソッド CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy) オーバーロードされます。 指定した数の一意のイベント開始時刻に基づいて、入力ストリームのイベントをイベントのウィンドウにグループ化します。異なる時刻に開始される新しいイベントが到着すると、ウィンドウはスライドします。 (CepStream によって定義されています。)
パブリック拡張メソッド CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy) オーバーロードされます。 指定した数の一意のイベント開始時刻に基づいて、入力ストリームのイベントをイベントのウィンドウにグループ化します。異なる時刻に開始される新しいイベントが到着すると、ウィンドウはスライドします。 (CepStream によって定義されています。)
パブリック拡張メソッド GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) オーバーロードされます。 指定されたグループ化キーによって入力ストリームをパーティション分割します。 (CepStream によって定義されています。)
パブリック拡張メソッド GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) オーバーロードされます。 指定されたキー セレクター関数でソース ストリームをグループ化し、要素セレクター関数を使用して結果を射影します。 (CepStream によって定義されています。)
パブリック拡張メソッド HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan) オーバーロードされます。 既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。 (CepStream によって定義されています。)
パブリック拡張メソッド HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime) オーバーロードされます。 既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 (CepStream によって定義されています。)
パブリック拡張メソッド HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。 (CepStream によって定義されています。)
パブリック拡張メソッド HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 (CepStream によって定義されています。)
パブリック拡張メソッド HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 (CepStream によって定義されています。)
パブリック拡張メソッド HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) オーバーロードされます。 ウィンドウは、一定のウィンドウ サイズとホップ サイズの期間によって定義されます。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 (CepStream によって定義されています。)
パブリック拡張メソッド IsEmpty< (Of < <' (TPayload> ) > > ) Left Anti Semi Join (LASJ) を示すためにクエリ内で使用される関数です。 (CepStream によって定義されています。)
パブリック拡張メソッド Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) 指定された結合キーで、外部ストリームのイベントを内部ストリームのイベントと結合します。 (CepStream によって定義されています。)
パブリック拡張メソッド Select< (Of < <' (TPayload, TResult> ) > > ) 射影式を使用して入力ストリームからイベントを射影します。 (CepStream によって定義されています。)
パブリック拡張メソッド SelectMany< (Of < <' (TInput, TBind, TResult> ) > > ) 2 つの入力ストリームのクロス結合に基づいて、1 つのストリームを生成します。 (CepStream によって定義されています。)
パブリック拡張メソッド ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) オーバーロードされます。 イベントの開始時刻を、有効期間を変更せずに新しいタイムスタンプにシフトします。 (CepStream によって定義されています。)
パブリック拡張メソッド ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) オーバーロードされます。 イベントの開始時刻を、有効期間を変更せずに指定の期間シフトします。 (CepStream によって定義されています。)
パブリック拡張メソッド SnapshotWindow< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。各ウィンドウは、ストリーム内の最も近いイベント エンドポイントによって定義されるスナップショット ウィンドウです。 (CepStream によって定義されています。)
パブリック拡張メソッド SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。各ウィンドウは、ストリーム内の最も近いイベント エンドポイントによって定義されるスナップショット ウィンドウです。 (CepStream によって定義されています。)
パブリック拡張メソッド SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。各ウィンドウは、ストリーム内の最も近いイベント エンドポイントによって定義されるスナップショット ウィンドウです。 (CepStream によって定義されています。)
パブリック拡張メソッド ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 エッジ イベントの CepStream を、IEnumerable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 (CepStream によって定義されています。)
パブリック拡張メソッド ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) オーバーロードされます。 エッジ イベントの CepStream を、指定されたイベントの順序で、IEnumerable インターフェイスを実装するイベント シンクに変換します。 (CepStream によって定義されています。)
パブリック拡張メソッド ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 エッジ イベントの CepStream を、IObservable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 (ObservableCepStream によって定義されています。)
パブリック拡張メソッド ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) オーバーロードされます。 エッジ イベントの CepStream を、指定されたイベントの順序で、IObservable インターフェイスを実装するイベント シンクに変換します。 (ObservableCepStream によって定義されています。)
パブリック拡張メソッド ToEnumerable< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 イベントのストリームを、イベント ヘッダーの削除と CTI イベントの破棄によって、列挙可能な出力に変換します。 (CepStream によって定義されています。)
パブリック拡張メソッド ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) オーバーロードされます。 イベントのストリームを、イベント ヘッダーの削除と CTI イベントの破棄によって、指定されたイベントの順序で、列挙可能な出力に変換します。 (CepStream によって定義されています。)
パブリック拡張メソッド ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 間隔イベントの CepStream を、IEnumerable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 (CepStream によって定義されています。)
パブリック拡張メソッド ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) オーバーロードされます。 間隔イベントの CepStream を、指定されたイベントの順序で、IEnumerable インターフェイスを実装するイベント シンクに変換します。 (CepStream によって定義されています。)
パブリック拡張メソッド ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 間隔イベントの CepStream を、IObservable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 (ObservableCepStream によって定義されています。)
パブリック拡張メソッド ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) オーバーロードされます。 間隔イベントの CepStream を、指定されたイベントの順序で、IObservable インターフェイスを実装するイベント シンクに変換します。 (ObservableCepStream によって定義されています。)
パブリック拡張メソッド ToObservable< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 イベントのストリームを、イベント ヘッダーの削除と CTI イベントの破棄によって、監視可能な出力に変換します。 (ObservableCepStream によって定義されています。)
パブリック拡張メソッド ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) オーバーロードされます。 イベントのストリームを、イベント ヘッダーの削除と CTI イベントの破棄によって、指定されたイベントの順序で、監視可能な出力に変換します。 (ObservableCepStream によって定義されています。)
パブリック拡張メソッド ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 ポイント イベントの CepStream を、IEnumerable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 (CepStream によって定義されています。)
パブリック拡張メソッド ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) オーバーロードされます。 ポイント イベントの CepStream を、指定されたイベントの順序で、IEnumerable インターフェイスを実装するイベント シンクに変換します。 (CepStream によって定義されています。)
パブリック拡張メソッド ToPointEventStream< (Of < <' (TPayload> ) > > ) イベント開始時刻だけは変更せずに、入力ストリーム内のイベントをポイント イベントに変更します。 (CepStream によって定義されています。)
パブリック拡張メソッド ToPointObservable< (Of < <' (TPayload> ) > > )() () () () オーバーロードされます。 ポイント イベントの CepStream を、IObservable インターフェイスを実装するイベント シンクに変換します。イベントの順序は FullyOrdered です。 (ObservableCepStream によって定義されています。)
パブリック拡張メソッド ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) オーバーロードされます。 ポイント イベントの CepStream を、指定されたイベントの順序で、IObservable インターフェイスを実装するイベント シンクに変換します。 (ObservableCepStream によって定義されています。)
パブリック拡張メソッド TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan) オーバーロードされます。 既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウとは、ウィンドウ サイズとホップ サイズが同一の特殊なホッピング ウィンドウです。 (CepStream によって定義されています。)
パブリック拡張メソッド TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime) オーバーロードされます。 既定の出力ポリシーでストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウとは、ウィンドウ サイズとホップ サイズが同一の特殊なホッピング ウィンドウです。 ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 (CepStream によって定義されています。)
パブリック拡張メソッド TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウとは、ウィンドウ サイズとホップ サイズが同一の特殊なホッピング ウィンドウです。 (CepStream によって定義されています。)
パブリック拡張メソッド TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウは、ウィンドウ サイズとホップ サイズが同一の特殊な種類のホッピング ウィンドウです。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 (CepStream によって定義されています。)
パブリック拡張メソッド TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウは、ウィンドウ サイズとホップ サイズが同一の特殊な種類のホッピング ウィンドウです。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 (CepStream によって定義されています。)
パブリック拡張メソッド TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) オーバーロードされます。 ストリームを変換して、各メンバーが CepWindow であるウィンドウ ストリームにします。タンブリング ウィンドウは、ウィンドウ サイズとホップ サイズが同一の特殊な種類のホッピング ウィンドウです。ウィンドウの開始位置の参照として、配置の時刻を指定することもできます。 (CepStream によって定義されています。)
パブリック拡張メソッド Union< (Of < <' (TPayload> ) > > ) 2 つのストリームの和集合を 1 つのストリームにします。 (CepStream によって定義されています。)
パブリック拡張メソッド Where< (Of < <' (TPayload> ) > > ) 指定したフィルター関数を使用して、入力ストリームのイベントをフィルター選択します。 (CepStream によって定義されています。)

Top

説明

CEP クエリを記述するには、適切なストリーム定義を行う必要があります。このクラスにより、CepStream オブジェクトを作成するさまざまなメソッドが提供されます。

スレッド セーフ

この型の public static (Visual Basic では Shared) のメンバーはすべて、スレッド セーフです。インスタンス メンバーの場合は、スレッド セーフであるとは限りません。

関連項目

参照

Microsoft.ComplexEventProcessing.Linq 名前空間