CepStreamOperator Class

 

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

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

Inheritance Hierarchy

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

Syntax

[DataContractAttribute]
public abstract class CepStreamOperator
[DataContractAttribute]
public ref class CepStreamOperator abstract 
[<AbstractClass>]
[<DataContractAttribute>]
type CepStreamOperator = class end
<DataContractAttribute>
Public MustInherit Class CepStreamOperator

Properties

Name Description
System_CAPS_pubproperty 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.

System_CAPS_pubproperty 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.

Methods

Name Description
System_CAPS_pubmethod Equals(Object)

(Inherited from Object.)

System_CAPS_protmethod Finalize()

(Inherited from Object.)

System_CAPS_pubmethod GetHashCode()

(Inherited from Object.)

System_CAPS_pubmethod GetType()

(Inherited from Object.)

System_CAPS_protmethod MemberwiseClone()

(Inherited from Object.)

System_CAPS_pubmethod ToString()

(Inherited from Object.)

Remarks

The operator must be serializable using WCF DataContractSerializer.

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

Microsoft.ComplexEventProcessing.Extensibility Namespace

Return to top