Datenströme

Unter Datenströmen versteht man die klassischen Streams, die man beim Zugriff auf externe Daten kennt. Das Datenmodell von StreamInsight erlaubt dabei verschiedene Umgangsweisen mit solchen Streams.

Die einfachste Form eines Streams ist der CEPStream. Er transportiert die vorher definierte Ereignisklasse und kann direkt aus der Factory abgerufen werden.

CepStream<Order> producer = CepStream<Order>.Create("TypedSqlInPointOutPoint", typeof(SqlInputFactory),
    inputConfig, EventShape.Point);

Ist die Datenquelle vom Typ IObservable, kann direkt aus dem Objekt ein CEPStream erzeugt werden.

CEPStream<PayloadType> inputStream =
    myObservableSource.ToCepStream<PayloadType>(
        e => e.myTimeStamp);

Einen solchen Datenstrom kann man nun beliebig filtern, ...

Get Microsoft SQL Server 2008 R2 - Das Entwicklerbuch now with the O’Reilly learning platform.

O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.

Start your free trial