TypedEdgeInputAdapter<TPayload> Class
Base class for an input adapter that produces edge events which have a payload structure.
Namespace: Microsoft.ComplexEventProcessing.Adapters
Assembly: Microsoft.ComplexEventProcessing.Adapters (in Microsoft.ComplexEventProcessing.Adapters.dll)
Inheritance Hierarchy
System.Object
Microsoft.ComplexEventProcessing.Adapters.Adapter
Microsoft.ComplexEventProcessing.Adapters.InputAdapterBase
Microsoft.ComplexEventProcessing.Adapters.TypedInputAdapter<TEvent, TPayload>
Microsoft.ComplexEventProcessing.Adapters.TypedEdgeInputAdapter<TPayload>
Syntax
public abstract class TypedEdgeInputAdapter<TPayload> : TypedInputAdapter<EdgeEvent<TPayload>, TPayload>
generic<typename TPayload>
public ref class TypedEdgeInputAdapter abstract : TypedInputAdapter<EdgeEvent<TPayload>^, TPayload>
[<AbstractClass>]
type TypedEdgeInputAdapter<'TPayload> =
class
inherit TypedInputAdapter<EdgeEvent<'TPayload>, 'TPayload>
end
Public MustInherit Class TypedEdgeInputAdapter(Of TPayload)
Inherits TypedInputAdapter(Of EdgeEvent(Of TPayload), TPayload)
Type Parameters
- TPayload
Payload structure for the edge events produced by this adapter.
Constructors
Name | Description | |
---|---|---|
TypedEdgeInputAdapter<TPayload>() | Initializes a new instance of the TypedEdgeInputAdapter<TPayload> class. |
Properties
Name | Description | |
---|---|---|
AdapterState | Gets the state of the adapter.(Inherited from Adapter.) |
Methods
Name | Description | |
---|---|---|
CleanupResources() | Cleans up engine resources that are used by the adapter host.(Inherited from InputAdapterBase.) |
|
CreateInsertEvent(EdgeType) | Creates an edge Insert event. |
|
Dispose() | Releases all of the resources owned by the adapter host.(Inherited from Adapter.) |
|
Dispose(Boolean) | Implements the Dispose pattern. To be overridden by derived classes.(Inherited from Adapter.) |
|
Enqueue(EdgeEvent<TPayload>) | Enqueues the specified event into the stream that is associated with this adapter. |
|
EnqueueCtiEvent(DateTimeOffset) | Enqueues a Current Time Increment (CTI) event.(Inherited from InputAdapterBase.) |
|
Equals(Object) | (Inherited from Object.) |
|
Finalize() | (Inherited from Object.) |
|
GetHashCode() | (Inherited from Object.) |
|
GetType() | (Inherited from Object.) |
|
MemberwiseClone() | (Inherited from Object.) |
|
OnStopped() | This function is called when the adapter invokes Stopped() to stop itself. Enqueue the EndOfStream event and detach from query instance. After this point, the plan manager is free to shut down the query independently of the adapter.(Inherited from InputAdapterBase.) |
|
Ready() | Invoked by the adapter to signal to the engine that it is ready to be resumed. The engine will invoke Resume() only after the adapter has called Ready().(Inherited from Adapter.) |
|
ReleaseEvent(TEvent) | Releases the memory occupied by an event.(Inherited from TypedInputAdapter<TEvent, TPayload>.) |
|
Resume() | Calls Resume() on its own worker thread.(Inherited from Adapter.) |
|
Start() | Calls Start() on its own worker thread.(Inherited from Adapter.) |
|
Stop() | Notifies the adapter to stop as a result of stopping or aborting the query.(Inherited from Adapter.) |
|
Stopped() | Invoked by the adapter to notify the runtime that the adapter has shut down.(Inherited from Adapter.) |
|
ToString() | (Inherited from Object.) |
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.Adapters Namespace
Return to top