Interface IComputeClient
Client Compute API. See GetCompute() and GetCompute().
Namespace: Apache.Ignite.Core.Client.Compute
Assembly: Apache.Ignite.Core.dll
Syntax
public interface IComputeClientProperties
ClusterGroup
Gets the cluster group for this IComputeClient instance.
Declaration
IClientClusterGroup ClusterGroup { get; }Property Value
| Type | Description |
|---|---|
| IClientClusterGroup |
Methods
ExecuteJavaTask<TRes>(String, Object)
Executes Java task by class name.
Declaration
TRes ExecuteJavaTask<TRes>(string taskName, object taskArg)Parameters
| Type | Name | Description |
|---|---|---|
| System.String | taskName | Java task name. |
| System.Object | taskArg | Optional argument of task execution, can be null. |
Returns
| Type | Description |
|---|---|
| TRes | Task result. |
Type Parameters
| Name | Description |
|---|---|
| TRes | Type of task result. |
ExecuteJavaTaskAsync<TRes>(String, Object)
Executes Java task by class name.
Declaration
Task<TRes> ExecuteJavaTaskAsync<TRes>(string taskName, object taskArg)Parameters
| Type | Name | Description |
|---|---|---|
| System.String | taskName | Java task name. |
| System.Object | taskArg | Optional argument of task execution, can be null. |
Returns
| Type | Description |
|---|---|
| Task<TRes> | Task result. |
Type Parameters
| Name | Description |
|---|---|
| TRes | Type of task result. |
ExecuteJavaTaskAsync<TRes>(String, Object, CancellationToken)
Executes Java task by class name.
Declaration
Task<TRes> ExecuteJavaTaskAsync<TRes>(string taskName, object taskArg, CancellationToken cancellationToken)Parameters
| Type | Name | Description |
|---|---|---|
| System.String | taskName | Java task name. |
| System.Object | taskArg | Optional argument of task execution, can be null. |
| CancellationToken | cancellationToken | Cancellation token. |
Returns
| Type | Description |
|---|---|
| Task<TRes> | Task result. |
Type Parameters
| Name | Description |
|---|---|
| TRes | Type of task result. |
WithKeepBinary()
Returns a new instance of IComputeClient with binary mode enabled: Java task argument (on server side) and result (on client side) won't be deserialized.
Declaration
IComputeClient WithKeepBinary()Returns
| Type | Description |
|---|---|
| IComputeClient | New Compute instance with binary mode enabled. |
WithNoFailover()
Returns a new instance of IComputeClient with disabled failover. When failover is disabled, compute jobs won't be retried in case of node crashes.
Declaration
IComputeClient WithNoFailover()Returns
| Type | Description |
|---|---|
| IComputeClient | New Compute instance with disabled failover. |
WithNoResultCache()
Returns a new instance of IComputeClient with disabled result cache.
Declaration
IComputeClient WithNoResultCache()Returns
| Type | Description |
|---|---|
| IComputeClient | New Compute instance with disabled result cache. |
WithTimeout(TimeSpan)
Returns a new instance of IComputeClient with a timeout for all task executions.
Declaration
IComputeClient WithTimeout(TimeSpan timeout)Parameters
| Type | Name | Description |
|---|---|---|
| TimeSpan | timeout | Timeout. |
Returns
| Type | Description |
|---|---|
| IComputeClient | New Compute instance with timeout. |