CepEdgeStreamOperator<TInputPayload, TOutputPayload> Class

Creates a user-defined stream operator that processes edge events in sync time order.

Inheritance Hierarchy

System.Object
  Microsoft.ComplexEventProcessing.Extensibility.CepStreamOperator
    Microsoft.ComplexEventProcessing.Extensibility.CepStreamOperator<EdgeEvent<TInputPayload>, TInputPayload, TOutputPayload>
      Microsoft.ComplexEventProcessing.Extensibility.CepEdgeStreamOperator<TInputPayload, TOutputPayload>

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

Syntax

[DataContractAttribute]
public abstract class CepEdgeStreamOperator<TInputPayload, TOutputPayload> : CepStreamOperator<EdgeEvent<TInputPayload>, TInputPayload, TOutputPayload>

Type Parameters

  • TInputPayload
    The type of the input event payload.
  • TOutputPayload
    The type of the output event payload.

The CepEdgeStreamOperator<TInputPayload, TOutputPayload> type exposes the following members.

Constructors

  Name Description
Protected method CepEdgeStreamOperator<TInputPayload, TOutputPayload> Initializes a new instance of the CepEdgeStreamOperator<TInputPayload, TOutputPayload> class.

Top

Properties

  Name Description
Public property IsEmpty When overriden in a derived class, gets a value that indicates whether the internal state of the operator is empty. When true, the StreamInsight query engine may discard the operator instance to minimize memory utilization. (Inherited from CepStreamOperator.)
Public property NextCti When overridden in a derived class, gets the next point in time at which the operator will be asked to process a CTI event. If the value is null, or less than or equal to the sync time of the last processed event, then no CTI events will be passed to the ProcessEvent method. (Inherited from CepStreamOperator.)

Top

Methods

  Name Description
Public method Equals (Inherited from Object.)
Protected method Finalize (Inherited from Object.)
Public method GetHashCode (Inherited from Object.)
Public method GetType (Inherited from Object.)
Protected method MemberwiseClone (Inherited from Object.)
Public method ProcessEvent When overridden in a derived class, generates output and updates internal state of the operator in response to an input event. (Inherited from CepStreamOperator<TInputEvent, TInputPayload, TOutputPayload>.)
Public method ToString (Inherited from Object.)

Top

Remarks

The sync time for edge events is the StartTime for a start edge, the EndTime for an end edge, and the StartTime for a CTI.

For more information, see User-Defined Stream Operators.

Thread Safety

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

See Also

Reference

Microsoft.ComplexEventProcessing.Extensibility Namespace