API-Unterstützung für IObservable- und IEnumerable-Elemente in StreamInsight

In diesem Thema werden die API-Funktionen in StreamInsight zusammengefasst, von denen Ereignisquellen und -senken unterstützt werden, von denen die IObservable-Schnittstelle oder die IEnumerable-Schnittstelle implementiert werden.

API-Unterstützung für Observable- und Enumerable-Eingabe

Folgende API-Funktionen unterstützen Ereignisquellen, von denen die IObservable-Schnittstelle oder die IEnumerable-Schnittstelle implementiert werden.

Erstellen von Eingaben

Erstellen von gebundenen Eingaben

Erstellen Sie einen an eine Anwendung gebundenen Eingabedatenstrom, indem Sie eine der folgenden Überladungen für die Create-Methode der CepStream<(Of <(<'TPayload>)>)>-Klasse verwenden.

• Create(Application, String, Type, Object, EventShape)

• Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings)

• Create(Application, Uri, EventShape)

• Create(Application, Uri, EventShape, AdvanceTimeSettings)

Erstellen von Eingaben aus Observable-Eingaben

Übersetzen Sie eine IObservable-Ereignisquelle in einen Eingabedatenstrom, indem Sie eine der folgenden Überladungen für die ToStream-Methode der ObservableCepStream-Klasse verwenden.

• ToStream<(Of <<'(TPayload>)>>)(IObservable<(Of <<'(PointEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToPointStream<(Of <<'(TInput, TPayload>)>>)(IObservable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, PointEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

• ToStream<(Of <<'(TPayload>)>>)(IObservable<(Of <<'(IntervalEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToIntervalStream<(Of <<'(TInput, TPayload>)>>)(IObservable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, IntervalEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

• ToStream<(Of <<'(TPayload>)>>)(IObservable<(Of <<'(EdgeEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToEdgeStream<(Of <<'(TInput, TPayload>)>>)(IObservable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, EdgeEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

Erstellen von Eingaben aus Enumerable-Eingaben

Übersetzen Sie eine IEnumerable-Ereignisquelle in einen Eingabedatenstrom, indem Sie eine der folgenden Überladungen für die ToStream-Methode der CepStream-Klasse verwenden.

• ToStream

• ToPointStream<(Of <<'(TInput, TPayload>)>>)(IEnumerable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, PointEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

• ToStream<(Of <<'(TPayload>)>>)(IEnumerable<(Of <<'(IntervalEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToIntervalStream<(Of <<'(TInput, TPayload>)>>)(IEnumerable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, IntervalEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

• ToStream<(Of <<'(TPayload>)>>)(IEnumerable<(Of <<'(EdgeEvent<(Of <<'(TPayload>)>>)>)>>), Application, AdvanceTimeSettings, String)

• ToEdgeStream<(Of <<'(TInput, TPayload>)>>)(IEnumerable<(Of <<'(TInput>)>>), Application, Expression<(Of <<'(Func<(Of <<'(TInput, EdgeEvent<(Of <<'(TPayload>)>>)>)>>)>)>>), AdvanceTimeSettings, String)

Beschreiben zeitbezogener Merkmale

Beschreiben Sie zeitbezogene Merkmale der Quelldaten, indem Sie einen der folgenden Helfer für die AdvanceTimeSettings-Klasse verwenden.

• IncreasingStartTime

• StrictlyIncreasingStartTime

• UnorderedStartTime(TimeSpan)

Zuordnung von Eingaben auf Punkt- oder Intervallereignisse bzw. Edge-Ereignisse

Ordnen Sie Eingabedaten Punkt- oder Intervallereignissen bzw. Edge-Ereignissen zu, indem Sie folgende Methoden in einem Ausdruck verwenden, der an eine Überladung der ToStream-Methode übergeben wird.

Zuordnung von Eingaben zu Punktereignissen

Ordnen Sie Eingabedaten Punktereignissen und den entsprechenden CTI-Ereignissen zu, indem Sie folgende Methoden der PointEvent-Klasse oder der PointEvent<(Of <(<'TPayload>)>)>-Klasse in einem Ausdruck verwenden, der an eine Überladung der ToStream-Methode übergeben wird.

• CreateInsert<(Of <<'(TPayload>)>>)(DateTimeOffset, TPayload)

• CreateCti<(Of <<'(TPayload>)>>)(DateTimeOffset)

• CreateInsert(DateTimeOffset, TPayload)

• CreateCti(DateTimeOffset)

Zuordnung von Eingaben zu Intervallereignissen

Ordnen Sie Eingabedaten Intervallereignissen und den entsprechenden CTI-Ereignissen zu, indem Sie folgende Methoden der IntervalEvent-Klasse oder der IntervalEvent<(Of <(<'TPayload>)>)>-Klasse in einem Ausdruck verwenden, der an eine Überladung der ToStream-Methode übergeben wird.

• CreateInsert<(Of <<'(TPayload>)>>)(DateTimeOffset, DateTimeOffset, TPayload)

• CreateCti<(Of <<'(TPayload>)>>)(DateTimeOffset)

• CreateInsert(DateTimeOffset, DateTimeOffset, TPayload)

• CreateCti(DateTimeOffset)

Erstellen von Edge-Ereignissen

Ordnen Sie Eingabedaten Edge-Ereignissen und den entsprechenden CTI-Ereignissen zu, indem Sie folgende Methoden der EdgeEvent-Klasse oder der EdgeEvent<(Of <(<'TPayload>)>)>-Klasse in einem Ausdruck verwenden, der an eine Überladung der ToStream-Methode übergeben wird.

• CreateStart<(Of <<'(TPayload>)>>)(DateTimeOffset, TPayload)

• CreateEnd<(Of <<'(TPayload>)>>)(DateTimeOffset, DateTimeOffset, TPayload)

• CreateCti<(Of <<'(TPayload>)>>)(DateTimeOffset)

• CreateStart(DateTimeOffset, TPayload)

• CreateEnd(DateTimeOffset, DateTimeOffset, TPayload)

• CreateCti(DateTimeOffset)

API-Unterstützung für Observable- und Enumerable-Ausgaben

Folgende API-Funktionen unterstützen Ereignissenken, von denen die IObservable-Schnittstelle oder die IEnumerable-Schnittstelle implementiert werden.

Erstellen von Ausgaben

Übersetzen Sie einen Ereignisdatenstrom in eine IObservable-Ausgabe für eine bestimmte Ereignisform, indem Sie eine der folgenden Methoden der ObservableCepStream-Klasse verwenden.

• ToObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToPointObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToPointObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToIntervalObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToIntervalObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToEdgeObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToEdgeObservable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

Übersetzen Sie einen Ereignisdatenstrom in eine IEnumerable-Ausgabe für eine bestimmte Ereignisform, indem Sie eine der folgenden Methoden der CepStream-Klasse verwenden.

• ToEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToPointEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToPointEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToIntervalEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToIntervalEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

• ToEdgeEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>))

• ToEdgeEnumerable<(Of <<'(TPayload>)>>)(CepStream<(Of <<'(TPayload>)>>), StreamEventOrder)

Zuordnung von Ausgaben

Zuordnung von Observable-Ausgaben

Verwenden Sie die folgenden Methoden von ObservableCepStream, um Observable-Ausgaben zuzuordnen.

• Select<(Of <<'(TInput, TOutput>)>>)(ICepObservable<(Of <<'(TInput>)>>), Expression<(Of <<'(Func<(Of <<'(TInput, TOutput>)>>)>)>>))

• Where<(Of <<'(TInput>)>>)(ICepObservable<(Of <<'(TInput>)>>), Expression<(Of <<'(Func<(Of <<'(TInput, Boolean>)>>)>)>>))

Zuordnung von Enumerable-Ausgaben

Verwenden Sie die folgenden Methoden von CepStream, um Enumerable-Ausgaben zuzuordnen.

• Select<(Of <<'(TInput, TOutput>)>>)(ICepEnumerable<(Of <<'(TInput>)>>), Expression<(Of <<'(Func<(Of <<'(TInput, TOutput>)>>)>)>>))

• Where<(Of <<'(TInput>)>>)(ICepEnumerable<(Of <<'(TInput>)>>), Expression<(Of <<'(Func<(Of <<'(TInput, Boolean>)>>)>)>>))

Erweiterte Schnittstellen für Ereignissenken

Die oben beschriebenen Methoden zur Erstellung und Filterung von Ausgaben geben Ereignissenken zurück, von denen die Schnittstellen implementiert werden, die die grundlegenden IObservable-Schnittstelle und die IEnumerable-Schnittstelle erweitern. Die erweiterten Schnittstellen dienen insbesondere zur Bereitstellung eines Abfragenamens zum Debuggen.

• ICepObservable<(Of <(<'T>)>)>

• ICepEnumerable<(Of <(<'T>)>)>