PartitionedStreamEvent<TKey,TPayload> Struct

Reference

Definition

Namespace:: Microsoft.StreamProcessing

Assembly:: Microsoft.StreamProcessing.Common.dll

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Represents a partitioned Stream event

[System.Runtime.Serialization.DataContract]
public struct PartitionedStreamEvent<TKey,TPayload>

type PartitionedStreamEvent<'Key, 'Payload> = struct

Public Structure PartitionedStreamEvent(Of TKey, TPayload)

Type Parameters

TKey

Type of payload for the event

TPayload

Type of payload for the event

Inheritance: ValueType
PartitionedStreamEvent<TKey,TPayload>

Attributes: DataContractAttribute

Constructors

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

Creates a new stream event with the given temporal parameters.

Fields

OtherTime	End-time for the event For a start edge, sync-time is the start time of the event (other-time is set to StreamEvent.InfinitySyncTime) For an end edge, sync-time is the end-time and other-time is the original start time for the event For an interval event, sync-time and other-time refer to the start and end times for the event For a punctuation, sync-time is set to the timetamp of the punctuation, while other-time is set to long.MinValue
PartitionKey	Partition key for the event
Payload	Payload of the event
SyncTime	Start-time for the event For a start edge, sync-time is the start time of the event (other-time is set to StreamEvent.InfinitySyncTime) For an end edge, sync-time is the end-time and other-time is the original start time for the event For an interval event, sync-time and other-time refer to the start and end times for the event For a punctuation, sync-time is set to the timetamp of the punctuation, while other-time is set to long.MinValue

Properties

EndTime	Get the end time of the logical event interval for this event
IsData	Check if the event is data (start edge, end edge, or interval)
IsEnd	Check if the event is an end-edge
IsInterval	Check if the event is an interval event
IsPoint	Check if the event is a point event (an interval event of length one)
IsPunctuation	Check if the event is a punctuation
IsStart	Check is the event is a start edge
Kind	Kind of the event
StartTime	Get the start time of the logical event interval for this event

Methods

ToString()

Return a string version of the event

Extension Methods

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.

Applies to