VertexInputTRecord, TTime InterfaceNaiad Help

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

Defines the input of a vertex, which must process messages and manage re-entrancy for the runtime.

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 interface VertexInput<TRecord, TTime>
where TTime : Object, Time<TTime>

Type Parameters

TRecord
The type of records accepted by thie input.
TTime
The type of timestamp on the records accepted by this input.

The VertexInputTRecord, TTime type exposes the following members.

Methods

  NameDescription
Public methodFlush
Ensures that before returning all messages are sent and all progress traffic has been presented to the worker.
Public methodOnReceive
Callback for a message containing several records.
Public methodSerializedMessageReceived
Callback for a serialized message.
Top
Properties

  NameDescription
Public propertyAvailableEntrancy
Indicates whether the destination vertex can be currently re-entered. Decremented and incremented by Naiad.
Public propertyLoggingEnabled
Reports and sets the status of logging; infrequently supported.
Public propertyVertex
The vertex hosting the input.
Top
See Also

Reference