IQWindowedStreamable<TPayload> Interface

Represents a windowed temporal stream query.

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

Syntax

'Declaration
Public Interface IQWindowedStreamable(Of TPayload) _
    Inherits IQStreamable, IWindowedStreamable(Of TPayload)
'Usage
Dim instance As IQWindowedStreamable(Of TPayload)
public interface IQWindowedStreamable<TPayload> : IQStreamable, 
    IWindowedStreamable<TPayload>
generic<typename TPayload>
public interface class IQWindowedStreamable : IQStreamable, 
    IWindowedStreamable<TPayload>
type IQWindowedStreamable<'TPayload> =  
    interface 
        interface IQStreamable 
        interface IWindowedStreamable<'TPayload>
    end
JScript does not support generic types and methods.

Type Parameters

  • TPayload
    The type of the payload.

The IQWindowedStreamable<TPayload> type exposes the following members.

Properties

  Name Description
Public property Expression Gets expression describing the query part. (Inherited from IQStreamable.)
Public property Provider Gets the LINQ provider for the temporal stream query part. (Inherited from IQStreamable.)

Top

Extension Methods

  Name Description
Public Extension Method Select<TSource, TResult> Projection method supporting aggregate computations over windows. (Defined by QStreamable.)
Public Extension Method SelectMany<TSource, TResult>(Expression<Func<IQWindowSource<TSource>, IQWindowResult<TResult>>>) Overloaded. Binds operator returning a stream of results given a function from window to window results. (Defined by QStreamable.)
Public Extension Method SelectMany<TSource, TBind, TResult>(Expression<Func<IQWindowSource<TSource>, IQWindowResult<TBind>>>, Expression<Func<Unit, TBind, TResult>>) Overloaded. Binds operator returning a stream of results given a function from window to window results. (Defined by QStreamable.)

Top

See Also

Reference

Microsoft.ComplexEventProcessing.Linq Namespace