Export (0) Print
Expand All
This topic has not yet been rated - Rate this topic

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.
Did you find this helpful?
(1500 characters remaining)
Thank you for your feedback
Show:
© 2014 Microsoft. All rights reserved.