StreamCache<TKey,TPayload> Class

Definition

Stores a complete stream in a highly efficient, Trill friendly manner for subsequent iteration over
the data.

public sealed class StreamCache<TKey,TPayload> : Microsoft.StreamProcessing.Streamable<TKey,TPayload>, IDisposable
type StreamCache<'Key, 'Payload> = class
    inherit Streamable<'Key, 'Payload>
    interface IDisposable
Public NotInheritable Class StreamCache(Of TKey, TPayload)
Inherits Streamable(Of TKey, TPayload)
Implements IDisposable

Type Parameters

TKey
TPayload
Inheritance
Microsoft.StreamProcessing.Streamable<TKey,TPayload>
StreamCache<TKey,TPayload>
Implements

Methods

ComputeSize()

Returns the number of elements of type T contained in this cache.

Dispose()

Frees up all of the elements in the cache.

Subscribe(IStreamObserver<TKey,TPayload>)

Callback method for downstream operators to register subscription to the output of the current operator

Applies to