QStreamable Class

Represents operator extension methods for IQStreamable temporal stream queries.

System.Object
  Microsoft.ComplexEventProcessing.Linq.QStreamable

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

public static class QStreamable

The QStreamable type exposes the following members.

  NameDescription
Public methodStatic memberAlterEventDuration<TPayload>Alters the duration of events without affecting start time.
Public methodStatic memberAlterEventLifetime<TPayload>Alters the lifetime of events.
Public methodStatic memberAlterEventStartTime<TPayload>Alters the start time of events without affecting duration.
Public methodStatic memberClipEventDuration<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 memberClipEventDuration<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 memberCountWindow<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 memberGroupBy<TPayload, TKey>(IQStreamable<TPayload>, Expression<Func<TPayload, TKey>>)Partition operator.
Public methodStatic memberGroupBy<TSource, TKey, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>)Partition operator.
Public methodStatic memberHoppingWindow<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 memberHoppingWindow<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 memberJoin<TLeft, TRight, TKey, TResult>Joins events with coincident lifetimes and matching key values.
Public methodStatic memberLeftAntiJoin<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 memberLeftAntiJoin<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 memberMulticast<TSource, TResult>Multicast operator.
Public methodStatic memberOrderBy<TPayload, TKey>Orders the contents of a window based on a key.
Public methodStatic memberOrderByDescending<TPayload, TKey>Orders the contents of a window based on a key in descending order.
Public methodStatic memberScan<TSourceEvent, TSource, TResult>Scans a stream using a user-defined stream operator.
Public methodStatic memberSelect<TSource, TResult>(IQOrderedWindow<TSource>, Expression<Func<TSource, TResult>>)Projection operator over ordered window.
Public methodStatic memberSelect<TSource, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TResult>>)Projection operator.
Public methodStatic memberSelect<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<CepWindow<TSource>, TResult>>)Projection method supporting aggregate computations over windows.
Public methodStatic memberSelectMany<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 memberSelectMany<TKey, TSource, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>)Merges operator for partitioned stream.
Public methodStatic memberSelectMany<TLeft, TRight, TResult>(IQStreamable<TLeft>, Expression<Func<Unit, IQStreamable<TRight>>>, Expression<Func<TLeft, TRight, TResult>>)Cross-join operator.
Public methodStatic memberSelectMany<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 memberSelectMany<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 memberSelectMany<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 memberShiftEventTime<TPayload>Shifts events by offsets specified by the shiftSelector parameter.
Public methodStatic memberSnapshotWindow<TPayload>Produces a windowed stream based on snapshots. Windows are defined by event boundaries in source.
Public methodStatic memberTake<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 memberTake<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 memberThenBy<TPayload, TKey>Adds an ordering key to an ordered window definition.
Public methodStatic memberThenByDescending<TPayload, TKey>Adds an ordering key to an ordered window definition where the key is used for descending order.
Public methodStatic memberToPointEventStream<TPayload>Turns events in the input stream into point events.
Public methodStatic memberTumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan)Produces a windowed stream based on window definition.
Public methodStatic memberTumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, DateTime)Produces a windowed stream based on window definition.
Public methodStatic memberUnion<TPayload>Union operator.
Public methodStatic memberUserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepOperator<TSource, TResult>>>)Applies a user-defined operator to a window.
Public methodStatic memberUserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepTimeSensitiveOperator<TSource, TResult>>>)Applies a user-defined operator to a window.
Public methodStatic memberWhere<TPayload>Selection operator.
Top

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