Export (0) Print
Expand All

IQStreamable<TPayload> Interface

Represents a base interface for parts of a temporal stream query with the specified type of payload.

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

public interface IQStreamable<TPayload> : IStreamable<TPayload>, 
	IQStreamable

Type Parameters

TPayload

The type of the payload.

The IQStreamable<TPayload> type exposes the following members.

  NameDescription
Public propertyExpression Gets expression describing the query part. (Inherited from IQStreamable.)
Public propertyProvider Gets the LINQ provider for the temporal stream query part. (Inherited from IQStreamable.)
Top

  NameDescription
Public Extension MethodAlterEventDuration<TPayload>Alters the duration of events without affecting start time. (Defined by QStreamable.)
Public Extension MethodAlterEventLifetime<TPayload>Alters the lifetime of events. (Defined by QStreamable.)
Public Extension MethodAlterEventStartTime<TPayload>Alters the start time of events without affecting duration. (Defined by QStreamable.)
Public Extension MethodBind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<EdgeEvent<TPayload>>>)Overloaded. Binds temporal stream to edge event observer parameterized on high-water mark and offset. (Defined by RemoteProvider.)
Public Extension MethodBind<TPayload>(IRemoteObserver<EdgeEvent<TPayload>>)Overloaded. Binds temporal stream to edge event observer sink. (Defined by RemoteProvider.)
Public Extension MethodBind<TPayload>(IRemoteObserver<IntervalEvent<TPayload>>)Overloaded. Binds temporal stream to interval event observer sink. (Defined by RemoteProvider.)
Public Extension MethodBind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<IntervalEvent<TPayload>>>)Overloaded. Binds temporal stream to interval event observer parameterized on high-water mark and offset. (Defined by RemoteProvider.)
Public Extension MethodBind<TPayload>(IRemoteObserver<TPayload>)Overloaded. Binds temporal stream to observer sink. (Defined by RemoteProvider.)
Public Extension MethodBind<TPayload>(IRemoteStreamableSink<TPayload>)Overloaded. Binds temporal stream source to temporal stream sink. (Defined by RemoteProvider.)
Public Extension MethodBind<TPayload>(IRemoteObserver<PointEvent<TPayload>>)Overloaded. Binds temporal stream to point event observer sink. (Defined by RemoteProvider.)
Public Extension MethodBind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<PointEvent<TPayload>>>)Overloaded. Binds temporal stream to point event observer parameterized on high-water mark and offset. (Defined by RemoteProvider.)
Public Extension MethodClipEventDuration<TSource, TClip>(IQStreamable<TClip>, Expression<Func<TSource, TClip, Boolean>>)Overloaded. Clips the end time of events in source to the start time of the next corresponding event in clip matching predicate. (Defined by QStreamable.)
Public Extension MethodClipEventDuration<TSource, TClip, TKey>(IQStreamable<TClip>, Expression<Func<TSource, TKey>>, Expression<Func<TClip, TKey>>)Overloaded. Clips the end time of events in source to the start time of the next corresponding event in clip with a equivalent key value. (Defined by QStreamable.)
Public Extension MethodCountWindow<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. (Defined by QStreamable.)
Public Extension MethodDeploy<TPayload> Deploys a remote temporal stream. (Defined by RemoteProvider.)
Public Extension MethodGroupBy<TPayload, TKey>(Expression<Func<TPayload, TKey>>)Overloaded. Partition operator. (Defined by QStreamable.)
Public Extension MethodGroupBy<TSource, TKey, TResult>(Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>)Overloaded. Partition operator. (Defined by QStreamable.)
Public Extension MethodHoppingWindow<TPayload>(TimeSpan, TimeSpan)Overloaded. Produces a windowed stream based on window definition. Hopping windows are characterized by a window duration and a hop size representing the window period. (Defined by QStreamable.)
Public Extension MethodHoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime)Overloaded. Produces a windowed stream based on window definition. Hopping windows are characterized by a window duration and a hop size representing the window period. (Defined by QStreamable.)
Public Extension MethodJoin<TLeft, TRight, TKey, TResult>Joins events with coincident lifetimes and matching key values. (Defined by QStreamable.)
Public Extension MethodLeftAntiJoin<TLeft, TRight>(IQStreamable<TRight>, Expression<Func<TLeft, TRight, Boolean>>)Overloaded. Returns left events when they do not coincide with any matching right events where events are matched based on predicate. (Defined by QStreamable.)
Public Extension MethodLeftAntiJoin<TLeft, TRight, TKey>(IQStreamable<TRight>, Expression<Func<TLeft, TKey>>, Expression<Func<TRight, TKey>>)Overloaded. Returns left events when they do not coincide with any matching right events where events are matched by key. (Defined by QStreamable.)
Public Extension MethodMulticast<TSource>(Expression<Func<IQStreamable<TSource>, IRemoteStreamableBinding>>)Overloaded. Defines a streamable binding based given a source. (Defined by RemoteProvider.)
Public Extension MethodMulticast<TSource, TResult>(Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>)Overloaded. Multicast operator. (Defined by QStreamable.)
Public Extension MethodSelect<TSource, TResult>Projection operator. (Defined by QStreamable.)
Public Extension MethodSelectMany<TLeft, TRight, TResult>Cross-join operator. (Defined by QStreamable.)
Public Extension MethodShiftEventTime<TPayload>Shifts events by offsets specified by the shiftSelector parameter. (Defined by QStreamable.)
Public Extension MethodSnapshotWindow<TPayload>Produces a windowed stream based on snapshots. Windows are defined by event boundaries in source. (Defined by QStreamable.)
Public Extension MethodToEdgeEnumerable<TPayload> Converts temporal stream to sequence. (Defined by RemoteProvider.)
Public Extension MethodToEdgeObservable<TPayload> Converts temporal stream to sequence. (Defined by RemoteProvider.)
Public Extension MethodToEnumerable<TPayload> Converts temporal stream to sequence. (Defined by RemoteProvider.)
Public Extension MethodToIntervalEnumerable<TPayload> Converts temporal stream to sequence. (Defined by RemoteProvider.)
Public Extension MethodToIntervalObservable<TPayload> Converts temporal stream to sequence. (Defined by RemoteProvider.)
Public Extension MethodToObservable<TPayload> Converts temporal stream to sequence. (Defined by RemoteProvider.)
Public Extension MethodToPointEnumerable<TPayload> Converts temporal stream to sequence. (Defined by RemoteProvider.)
Public Extension MethodToPointEventStream<TPayload>Turns events in the input stream into point events. (Defined by QStreamable.)
Public Extension MethodToPointObservable<TPayload> Converts temporal stream to sequence. (Defined by RemoteProvider.)
Public Extension MethodTumblingWindow<TPayload>(TimeSpan)Overloaded. Produces a windowed stream based on window definition. (Defined by QStreamable.)
Public Extension MethodTumblingWindow<TPayload>(TimeSpan, DateTime)Overloaded. Produces a windowed stream based on window definition. (Defined by QStreamable.)
Public Extension MethodUnion<TPayload>Union operator. (Defined by QStreamable.)
Public Extension MethodWhere<TPayload>Selection operator. (Defined by QStreamable.)
Top
Show:
© 2014 Microsoft