Share via


Streamable.RegisterBinaryInput Method

Definition

Overloads

RegisterBinaryInput<TKey,TPayload>(QueryContainer, Stream, IIngressScheduler, Boolean, StreamProperties<TKey,TPayload>, String)

Deserialize from binary stream to streamable

RegisterBinaryInput<TPayload>(QueryContainer, Stream, IIngressScheduler, Boolean, StreamProperties<Empty,TPayload>, String)

Deserialize from binary stream to streamable

RegisterBinaryInput<TKey,TPayload>(QueryContainer, Stream, IIngressScheduler, Boolean, StreamProperties<TKey,TPayload>, String)

Deserialize from binary stream to streamable

public static Microsoft.StreamProcessing.IIngressStreamable<TKey,TPayload> RegisterBinaryInput<TKey,TPayload> (this Microsoft.StreamProcessing.QueryContainer container, System.IO.Stream binaryStream, Microsoft.StreamProcessing.Serializer.IIngressScheduler scheduler = null, bool readPropertiesFromStream = false, Microsoft.StreamProcessing.StreamProperties<TKey,TPayload> inputProperties = null, string identifier = null);
static member RegisterBinaryInput : Microsoft.StreamProcessing.QueryContainer * System.IO.Stream * Microsoft.StreamProcessing.Serializer.IIngressScheduler * bool * Microsoft.StreamProcessing.StreamProperties<'Key, 'Payload> * string -> Microsoft.StreamProcessing.IIngressStreamable<'Key, 'Payload>
<Extension()>
Public Function RegisterBinaryInput(Of TKey, TPayload) (container As QueryContainer, binaryStream As Stream, Optional scheduler As IIngressScheduler = null, Optional readPropertiesFromStream As Boolean = false, Optional inputProperties As StreamProperties(Of TKey, TPayload) = null, Optional identifier As String = null) As IIngressStreamable(Of TKey, TPayload)

Type Parameters

TKey
TPayload

Parameters

container
QueryContainer
binaryStream
Stream
scheduler
IIngressScheduler
readPropertiesFromStream
Boolean
identifier
String

Returns

Applies to

RegisterBinaryInput<TPayload>(QueryContainer, Stream, IIngressScheduler, Boolean, StreamProperties<Empty,TPayload>, String)

Deserialize from binary stream to streamable

public static Microsoft.StreamProcessing.IIngressStreamable<Microsoft.StreamProcessing.Empty,TPayload> RegisterBinaryInput<TPayload> (this Microsoft.StreamProcessing.QueryContainer container, System.IO.Stream binaryStream, Microsoft.StreamProcessing.Serializer.IIngressScheduler scheduler = null, bool readPropertiesFromStream = false, Microsoft.StreamProcessing.StreamProperties<Microsoft.StreamProcessing.Empty,TPayload> inputProperties = null, string identifier = null);
static member RegisterBinaryInput : Microsoft.StreamProcessing.QueryContainer * System.IO.Stream * Microsoft.StreamProcessing.Serializer.IIngressScheduler * bool * Microsoft.StreamProcessing.StreamProperties<Microsoft.StreamProcessing.Empty, 'Payload> * string -> Microsoft.StreamProcessing.IIngressStreamable<Microsoft.StreamProcessing.Empty, 'Payload>
<Extension()>
Public Function RegisterBinaryInput(Of TPayload) (container As QueryContainer, binaryStream As Stream, Optional scheduler As IIngressScheduler = null, Optional readPropertiesFromStream As Boolean = false, Optional inputProperties As StreamProperties(Of Empty, TPayload) = null, Optional identifier As String = null) As IIngressStreamable(Of Empty, TPayload)

Type Parameters

TPayload

Parameters

container
QueryContainer
binaryStream
Stream
scheduler
IIngressScheduler
readPropertiesFromStream
Boolean
inputProperties
StreamProperties<Empty,TPayload>
identifier
String

Returns

Applies to