Streamable.Cache<TKey,TPayload> Method

Definition

Caches the complete results computed by the streamable upon an immediate call to subscribe. This
call will block until the underlying query has fully executed and the result cached.

public static Microsoft.StreamProcessing.StreamCache<TKey,TPayload> Cache<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> stream, ulong limit = 0, bool inferProperties = false, bool coalesceEndEdges = false);
static member Cache : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * uint64 * bool * bool -> Microsoft.StreamProcessing.StreamCache<'Key, 'Payload>
<Extension()>
Public Function Cache(Of TKey, TPayload) (stream As IStreamable(Of TKey, TPayload), Optional limit As ULong = 0, Optional inferProperties As Boolean = false, Optional coalesceEndEdges As Boolean = false) As StreamCache(Of TKey, TPayload)

Type Parameters

TKey

Type of key for stream

TPayload

Type of payload for stream

Parameters

stream
IStreamable<TKey,TPayload>

Instance of the stream to be cached

limit
UInt64

Limit on number of events to store in the cached stream

inferProperties
Boolean

Specifies whether each stream event in the incoming stream should be checked to infer the properties of no intervals and constant duration

coalesceEndEdges
Boolean

Whether or not we coalesce end edges with their starts into interval events

Returns

A streamable cache instance

Applies to