SinkBufferingVertexTOutput, TTime ClassNaiad Help

[This is preliminary documentation and is subject to change.]

Vertex with one input, which accumulates inputs and schedules itself for each time seen.
Inheritance Hierarchy

SystemObject
  Microsoft.Research.Naiad.DataflowVertex
    Microsoft.Research.Naiad.DataflowVertexTTime
      Microsoft.Research.Naiad.Dataflow.StandardVerticesSinkVertexTOutput, TTime
        Microsoft.Research.Naiad.Dataflow.StandardVerticesSinkBufferingVertexTOutput, TTime

Namespace: Microsoft.Research.Naiad.Dataflow.StandardVertices
Assembly: Microsoft.Research.Naiad (in Microsoft.Research.Naiad.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax

C#
public class SinkBufferingVertex<TOutput, TTime> : SinkVertex<TOutput, TTime>
where TTime : Object, Time<TTime>

Type Parameters

TOutput
Source record type
TTime
Time type

The SinkBufferingVertexTOutput, TTime type exposes the following members.

Constructors

  NameDescription
Public methodSinkBufferingVertexTOutput, TTime
Creates a new SinkBufferingStage
Top
Methods

  NameDescription
Public methodOnNotify
Indicates that all messages bearing the given time (or earlier) have been delivered.
(Overrides VertexTTimeOnNotify(TTime).)
Public methodOnReceive
Called when a message is received.
(Overrides SinkVertexTOutput, TTimeOnReceive(MessageTOutput, TTime).)
Top
Fields

  NameDescription
Protected fieldInput
Input buffer
Top
See Also

Reference