PartitionedPeriodicPunctuationPolicy Class

Definition

Specifies how to inject punctuations into the resulting stream. Since punctuations force output, this exposes a throughput/latency tradeoff.

[System.Runtime.Serialization.DataContract]
public class PartitionedPeriodicPunctuationPolicy
type PartitionedPeriodicPunctuationPolicy = class
Public Class PartitionedPeriodicPunctuationPolicy
Inheritance
PartitionedPeriodicPunctuationPolicy
Attributes

Constructors

PartitionedPeriodicPunctuationPolicy()

Empty constructor for serialization purposes.

Methods

Count(UInt64, UInt64)

Inject punctuations every n events. Optionally add a punctuation at infinity.

GetHashCode()

Provides a hash code for the PartitionedPeriodicPunctuationPolicy object.

None()

Don't inject any punctuations. Optionally add a punctuation at infinity. This is the default policy.

Time(UInt64, UInt64)

Inject punctuations every n time ticks. Optionally add a punctuation at infinity.

ToString()

Provides a string representation for the PartitionedPeriodicPunctuationPolicy object.

Applies to