CepStream.ToStream<TPayload> Method (IEnumerable<EdgeEvent<TPayload>>, Application, AdvanceTimeSettings, String)
Converts a CepStream of point events to a stream.
Namespace: Microsoft.ComplexEventProcessing.Linq
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public static CepStream<TPayload> ToStream<TPayload>(
this IEnumerable<EdgeEvent<TPayload>> source,
Application application,
AdvanceTimeSettings advanceTimeSettings = null,
string streamName = null
)
public:
generic<typename TPayload>
[ExtensionAttribute]
static CepStream<TPayload>^ ToStream(
IEnumerable<EdgeEvent<TPayload>^>^ source,
Application^ application,
AdvanceTimeSettings^ advanceTimeSettings = null,
String^ streamName = null
)
static member ToStream<'TPayload> :
source:IEnumerable<EdgeEvent<'TPayload>> *
application:Application *
advanceTimeSettings:AdvanceTimeSettings = null *
streamName:string = null -> CepStream<'TPayload>
<ExtensionAttribute>
Public Shared Function ToStream(Of TPayload) (
source As IEnumerable(Of EdgeEvent(Of TPayload)),
application As Application,
advanceTimeSettings As AdvanceTimeSettings,
streamName As String
) As CepStream(Of TPayload)
Parameters
source
Type: System.Collections.Generic.IEnumerable<EdgeEvent<TPayload>>The event source that implements the IEnumerable interface. This parameter cannot be null.
application
Type: Microsoft.ComplexEventProcessing.ApplicationAn application instance that hosts the event source.
advanceTimeSettings
Type: Microsoft.ComplexEventProcessing.AdvanceTimeSettingsSpecifies how to advance application time for the event source.
streamName
Type: System.StringA stream name supports “importing” CTI events from one stream to another using AdvanceTimeImportSettings.
Return Value
Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>
A stream definition for the enumerable event source that can be used to compose queries.
Type Parameters
- TPayload
The type of the event payload.
See Also
ToStream Overload
CepStream Class
Microsoft.ComplexEventProcessing.Linq Namespace
Return to top