PartitionedStreamEvent Class

Definition

Partitioned stream event helpers that do not depend on generic arguments.

public static class PartitionedStreamEvent
type PartitionedStreamEvent = class
Public Module PartitionedStreamEvent
Inheritance
PartitionedStreamEvent

Fields

InfinitySyncTime

The time value associated with infinity, or a value beyond all other possible concrete time values.

MaxSyncTime

The maximum possible time value processed by the system.

MinSyncTime

The minimum possible time value processed by the system.

Methods

CreateEnd<TKey,TPayload>(TKey, Int64, Int64, TPayload)

Create an end-edge event.

CreateInterval<TKey,TPayload>(TKey, Int64, Int64, TPayload)

Create an interval event.

CreatePoint<TKey,TPayload>(TKey, Int64, TPayload)

Create a point event (an interval event of length one).

CreatePunctuation<TKey,TPayload>(PartitionedStreamEvent<TKey,TPayload>, Int64)

Create a punctuation event, given an existing stream event as a template for the type of the event payload and the value of the partition key.

CreatePunctuation<TKey,TPayload>(TKey, Int64)

Create a punctuation event.

CreateStart<TKey,TPayload>(TKey, Int64, TPayload)

Create a start-edge event.

Applies to