Interface ICompute

Namespace

Apache.Ignite.Compute

Assembly

Apache.Ignite.dll

Ignite Compute API provides distributed job execution functionality.

public interface ICompute

Methods

SubmitAsync<TTarget, TArg, TResult>(IJobTarget<TTarget>, JobDescriptor<TArg, TResult>, TArg)

Submits a compute job represented by the given class for an execution on one of the specified nodes.

Task<IJobExecution<TResult>> SubmitAsync<TTarget, TArg, TResult>(IJobTarget<TTarget> target, JobDescriptor<TArg, TResult> jobDescriptor, TArg arg) where TTarget : notnull

Parameters

target IJobTarget<TTarget>

Job execution target. See factory methods in JobTarget.

jobDescriptor JobDescriptor<TArg, TResult>

Job descriptor.

arg TArg

Job argument.

Returns

Task<IJobExecution<TResult>>

A Task representing the asynchronous operation.

Type Parameters

TTarget

Job target type.

TArg

Job argument type.

TResult

Job result type.

SubmitAsync<TTarget, TArg, TResult>(IJobTarget<TTarget>, JobDescriptor<TArg, TResult>, TArg, CancellationToken)

Submits a compute job represented by the given class for an execution on one of the specified nodes.

Task<IJobExecution<TResult>> SubmitAsync<TTarget, TArg, TResult>(IJobTarget<TTarget> target, JobDescriptor<TArg, TResult> jobDescriptor, TArg arg, CancellationToken cancellationToken) where TTarget : notnull

Parameters

target IJobTarget<TTarget>

Job execution target. See factory methods in JobTarget.

jobDescriptor JobDescriptor<TArg, TResult>

Job descriptor.

arg TArg

Job argument.

cancellationToken CancellationToken

Cancellation token.

Returns

Task<IJobExecution<TResult>>

A Task representing the asynchronous operation.

Type Parameters

TTarget

Job target type.

TArg

Job argument type.

TResult

Job result type.

SubmitBroadcastAsync<TTarget, TArg, TResult>(IBroadcastJobTarget<TTarget>, JobDescriptor<TArg, TResult>, TArg)

Submits a compute job represented by the given class for an execution on the specified target.

Task<IBroadcastExecution<TResult>> SubmitBroadcastAsync<TTarget, TArg, TResult>(IBroadcastJobTarget<TTarget> target, JobDescriptor<TArg, TResult> jobDescriptor, TArg arg) where TTarget : notnull

Parameters

target IBroadcastJobTarget<TTarget>

Job target. See factory methods in BroadcastJobTarget.

jobDescriptor JobDescriptor<TArg, TResult>

Job descriptor.

arg TArg

Job argument.

Returns

Task<IBroadcastExecution<TResult>>

A Task representing the asynchronous operation.

Type Parameters

TTarget

Job target type.

TArg

Job argument type.

TResult

Job result type.

SubmitBroadcastAsync<TTarget, TArg, TResult>(IBroadcastJobTarget<TTarget>, JobDescriptor<TArg, TResult>, TArg, CancellationToken)

Submits a compute job represented by the given class for an execution on the specified target.

Task<IBroadcastExecution<TResult>> SubmitBroadcastAsync<TTarget, TArg, TResult>(IBroadcastJobTarget<TTarget> target, JobDescriptor<TArg, TResult> jobDescriptor, TArg arg, CancellationToken cancellationToken) where TTarget : notnull

Parameters

target IBroadcastJobTarget<TTarget>

Job target. See factory methods in BroadcastJobTarget.

jobDescriptor JobDescriptor<TArg, TResult>

Job descriptor.

arg TArg

Job argument.

cancellationToken CancellationToken

Cancellation token.

Returns

Task<IBroadcastExecution<TResult>>

A Task representing the asynchronous operation.

Type Parameters

TTarget

Job target type.

TArg

Job argument type.

TResult

Job result type.

SubmitMapReduceAsync<TArg, TResult>(TaskDescriptor<TArg, TResult>, TArg)

Submits a compute map-reduce task represented by the given class.

Task<ITaskExecution<TResult>> SubmitMapReduceAsync<TArg, TResult>(TaskDescriptor<TArg, TResult> taskDescriptor, TArg arg)

Parameters

taskDescriptor TaskDescriptor<TArg, TResult>

Task descriptor.

arg TArg

Job arguments.

Returns

Task<ITaskExecution<TResult>>

A Task representing the asynchronous operation.

Type Parameters

TArg

Task argument type.

TResult

Task result type.

SubmitMapReduceAsync<TArg, TResult>(TaskDescriptor<TArg, TResult>, TArg, CancellationToken)

Submits a compute map-reduce task represented by the given class.

Task<ITaskExecution<TResult>> SubmitMapReduceAsync<TArg, TResult>(TaskDescriptor<TArg, TResult> taskDescriptor, TArg arg, CancellationToken cancellationToken)

Parameters

taskDescriptor TaskDescriptor<TArg, TResult>

Task descriptor.

arg TArg

Job arguments.

cancellationToken CancellationToken

Cancellation token.

Returns

Task<ITaskExecution<TResult>>

A Task representing the asynchronous operation.

Type Parameters

TArg

Task argument type.

TResult

Task result type.