QStreamable Class

  • Article

Represents operator extension methods for IQStreamable temporal stream queries.

Inheritance Hierarchy

System.Object
  Microsoft.ComplexEventProcessing.Linq.QStreamable

Namespace:  Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)

Syntax

'Declaration
<ExtensionAttribute> _
Public NotInheritable Class QStreamable
'Usage

public static class QStreamable

[ExtensionAttribute]
public ref class QStreamable abstract sealed

[<AbstractClassAttribute>]
[<SealedAttribute>]
type QStreamable =  class end

public final class QStreamable

The QStreamable type exposes the following members.

Methods

  Name Description
Public methodStatic member AlterEventDuration<TPayload> Alters the duration of events without affecting start time.
Public methodStatic member AlterEventLifetime<TPayload> Alters the lifetime of events.
Public methodStatic member AlterEventStartTime<TPayload> Alters the start time of events without affecting duration.
Public methodStatic member ClipEventDuration<TSource, TClip>(IQStreamable<TSource>, IQStreamable<TClip>, Expression<Func<TSource, TClip, Boolean>>) Clips the end time of events in source to the start time of the next corresponding event in clip matching predicate.
Public methodStatic member ClipEventDuration<TSource, TClip, TKey>(IQStreamable<TSource>, IQStreamable<TClip>, Expression<Func<TSource, TKey>>, Expression<Func<TClip, TKey>>) Clips the end time of events in source to the start time of the next corresponding event in clip with a equivalent key value.
Public methodStatic member CountWindow<TPayload> Produces a windowed stream based on a count. Each window consists of events with count unique start times. The window slides when a new event arrives with a distinct start time.
Public methodStatic member GroupBy<TPayload, TKey>(IQStreamable<TPayload>, Expression<Func<TPayload, TKey>>) Partition operator.
Public methodStatic member GroupBy<TSource, TKey, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>) Partition operator.
Public methodStatic member HoppingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, TimeSpan) Produces a windowed stream based on window definition. Hopping windows are characterized by a window duration and a hop size representing the window period.
Public methodStatic member HoppingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, TimeSpan, DateTime) Produces a windowed stream based on window definition. Hopping windows are characterized by a window duration and a hop size representing the window period.
Public methodStatic member Join<TLeft, TRight, TKey, TResult> Joins events with coincident lifetimes and matching key values.
Public methodStatic member LeftAntiJoin<TLeft, TRight>(IQStreamable<TLeft>, IQStreamable<TRight>, Expression<Func<TLeft, TRight, Boolean>>) Returns left events when they do not coincide with any matching right events where events are matched based on predicate.
Public methodStatic member LeftAntiJoin<TLeft, TRight, TKey>(IQStreamable<TLeft>, IQStreamable<TRight>, Expression<Func<TLeft, TKey>>, Expression<Func<TRight, TKey>>) Returns left events when they do not coincide with any matching right events where events are matched by key.
Public methodStatic member Multicast<TSource, TResult> Multicast operator.
Public methodStatic member OrderBy<TPayload, TKey> Orders the contents of a window based on a key.
Public methodStatic member OrderByDescending<TPayload, TKey> Orders the contents of a window based on a key in descending order.
Public methodStatic member Scan<TSourceEvent, TSource, TResult> Scans a stream using a user-defined stream operator.
Public methodStatic member Select<TSource, TResult>(IQOrderedWindow<TSource>, Expression<Func<TSource, TResult>>) Projection operator over ordered window.
Public methodStatic member Select<TSource, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TResult>>) Projection operator.
Public methodStatic member Select<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<CepWindow<TSource>, TResult>>) Projection method supporting aggregate computations over windows.
Public methodStatic member SelectMany<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<IQWindowSource<TSource>, IQWindowResult<TResult>>>) Binds operator returning a stream of results given a function from window to window results.
Public methodStatic member SelectMany<TKey, TSource, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>) Merges operator for partitioned stream.
Public methodStatic member SelectMany<TLeft, TRight, TResult>(IQStreamable<TLeft>, Expression<Func<Unit, IQStreamable<TRight>>>, Expression<Func<TLeft, TRight, TResult>>) Cross-join operator.
Public methodStatic member SelectMany<TSource, TBind, TResult>(IQWindowedStreamable<TSource>, Expression<Func<IQWindowSource<TSource>, IQWindowResult<TBind>>>, Expression<Func<Unit, TBind, TResult>>) Binds operator returning a stream of results given a function from window to window results.
Public methodStatic member SelectMany<TKey, TSource, TBind, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TBind>>>, Expression<Func<IKey<TKey>, TBind, TResult>>) Merges operator for partitioned stream.
Public methodStatic member SelectMany<TKey, TSource, TBind, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>>, Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>>) Merges aggregate operator for partitioned stream.
Public methodStatic member ShiftEventTime<TPayload> Shifts events by offsets specified by the shiftSelector parameter.
Public methodStatic member SnapshotWindow<TPayload> Produces a windowed stream based on snapshots. Windows are defined by event boundaries in source.
Public methodStatic member Take<TPayload>(IQOrderedWindow<TPayload>, UInt32) Takes the top count elements from an ordered window. If there are ties, all elements with the lowest rank are returned.
Public methodStatic member Take<TSource, TResult>(IQOrderedWindow<TSource>, UInt32, Expression<Func<CepRankedEvent<TSource>, TResult>>) Takes the top count elements from an ordered window. If there are ties, all elements with the lowest rank are returned.
Public methodStatic member ThenBy<TPayload, TKey> Adds an ordering key to an ordered window definition.
Public methodStatic member ThenByDescending<TPayload, TKey> Adds an ordering key to an ordered window definition where the key is used for descending order.
Public methodStatic member ToPointEventStream<TPayload> Turns events in the input stream into point events.
Public methodStatic member TumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan) Produces a windowed stream based on window definition.
Public methodStatic member TumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, DateTime) Produces a windowed stream based on window definition.
Public methodStatic member Union<TPayload> Union operator.
Public methodStatic member UserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepOperator<TSource, TResult>>>) Applies a user-defined operator to a window.
Public methodStatic member UserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepTimeSensitiveOperator<TSource, TResult>>>) Applies a user-defined operator to a window.
Public methodStatic member Where<TPayload> Selection operator.

Top

Thread Safety

Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.

See Also

Reference

Microsoft.ComplexEventProcessing.Linq Namespace