[This is preliminary documentation and is subject to change.]
A repository for input records, stored indexed by time. Calls NotifyAt on record receipt.
Inheritance Hierarchy
Microsoft.Research.Naiad.DataflowVertexInputBufferTRecord, TTime
Namespace: Microsoft.Research.Naiad.Dataflow
Assembly: Microsoft.Research.Naiad (in Microsoft.Research.Naiad.dll) Version: 0.5.0.0 (0.5.0.0)
Syntax
C#
public class VertexInputBuffer<TRecord, TTime> : VertexInput<TRecord, TTime> where TTime : Object, Time<TTime>
Type Parameters
- TRecord
- The type of records in this buffer.
- TTime
- The type of timestamp by which this buffer is indexed.
The VertexInputBufferTRecord, TTime type exposes the following members.
Constructors
| Name | Description | |
|---|---|---|
 | VertexInputBufferTRecord, TTime |
Constructs new input buffer for the given vertex.
|
Methods
| Name | Description | |
|---|---|---|
| Checkpoint |
Checkpoints the contents of this buffer to the given NaiadWriter.
|
| Flush |
Flushes the associated vertex.
|
| GetRecordsAt |
Enumerates (and destroys) input records associated with the given time.
|
| OnReceive |
Buffers the content of the given message, and schedules
a corresponding notification on the owning Vertex.
|
| Restore |
Restores this buffer from the given NaiadReader.
|
| SerializedMessageReceived |
Buffers the content of the given serializedMessage, and
schedules a corresponding notification on the owning Vertex.
|
| ToString |
Returns a string representation of this buffer.
(Overrides ObjectToString.) |
Properties
| Name | Description | |
|---|---|---|
 | AvailableEntrancy |
Indicates available entrancy; always 1 as this class buffers everything.
|
| LoggingEnabled |
Controls whether logging occurs (presently disabled)
|
| Vertex |
The vertex to which this buffer belongs.
|
See Also