StreamCache<TKey,TPayload> Class
Definition
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.
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 |