Class ReceiverDescriptor<TItem, TArg, TResult>

Namespace

Apache.Ignite.Table

Assembly

Apache.Ignite.dll

Stream receiver descriptor with a result type.

public sealed record ReceiverDescriptor<TItem, TArg, TResult> : IEquatable<ReceiverDescriptor<TItem, TArg, TResult>>

Type Parameters

TItem

Streamer item type.

TArg

Argument type.

TResult

Result type.

Inheritance

object

ReceiverDescriptor<TItem, TArg, TResult>

Implements

IEquatable<ReceiverDescriptor<TItem, TArg, TResult>>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

ReceiverDescriptor(string, IEnumerable<DeploymentUnit>?, ReceiverExecutionOptions?, IMarshaller<TItem>?, IMarshaller<TArg>?, IMarshaller<TResult>?)

Stream receiver descriptor with a result type.

public ReceiverDescriptor(string ReceiverClassName, IEnumerable<DeploymentUnit>? DeploymentUnits = null, ReceiverExecutionOptions? Options = null, IMarshaller<TItem>? PayloadMarshaller = null, IMarshaller<TArg>? ArgumentMarshaller = null, IMarshaller<TResult>? ResultMarshaller = null)

Parameters

ReceiverClassName string

Name of the streamer receiver class to execute.

DeploymentUnits IEnumerable<DeploymentUnit>

Deployment units.

Options ReceiverExecutionOptions

Execution options.

PayloadMarshaller IMarshaller<TItem>

Payload marshaller.

ArgumentMarshaller IMarshaller<TArg>

Argument marshaller.

ResultMarshaller IMarshaller<TResult>

Result marshaller.

ReceiverDescriptor(Type, IEnumerable<DeploymentUnit>?, ReceiverExecutionOptions?, IMarshaller<TItem>?, IMarshaller<TArg>?, IMarshaller<TResult>?)

Initializes a new instance of the ReceiverDescriptor<TItem, TArg, TResult> class.

public ReceiverDescriptor(Type type, IEnumerable<DeploymentUnit>? deploymentUnits = null, ReceiverExecutionOptions? options = null, IMarshaller<TItem>? payloadMarshaller = null, IMarshaller<TArg>? argumentMarshaller = null, IMarshaller<TResult>? resultMarshaller = null)

Parameters

type Type

Receiver type.

deploymentUnits IEnumerable<DeploymentUnit>

Deployment units.

options ReceiverExecutionOptions

Options.

payloadMarshaller IMarshaller<TItem>

Payload marshaller.

argumentMarshaller IMarshaller<TArg>

Argument marshaller.

resultMarshaller IMarshaller<TResult>

Result marshaller.

Properties

ArgumentMarshaller

Argument marshaller.

public IMarshaller<TArg>? ArgumentMarshaller { get; init; }

Property Value

IMarshaller<TArg>

DeploymentUnits

Deployment units.

public IEnumerable<DeploymentUnit>? DeploymentUnits { get; init; }

Property Value

IEnumerable<DeploymentUnit>

Options

Execution options.

public ReceiverExecutionOptions? Options { get; init; }

Property Value

ReceiverExecutionOptions

PayloadMarshaller

Payload marshaller.

public IMarshaller<TItem>? PayloadMarshaller { get; init; }

Property Value

IMarshaller<TItem>

ReceiverClassName

Name of the streamer receiver class to execute.

public string ReceiverClassName { get; init; }

Property Value

string

ResultMarshaller

Result marshaller.

public IMarshaller<TResult>? ResultMarshaller { get; init; }

Property Value

IMarshaller<TResult>