IntegerDecrementJob

java.lang.Object

org.apache.ignite.example.serialization.IntegerDecrementJob

All Implemented Interfaces:: ComputeJob<Integer,Integer>

public class IntegerDecrementJob extends Object implements ComputeJob<Integer,Integer>

Constructor Summary

Constructors

Constructor

Description

IntegerDecrementJob()
Method Summary

Modifier and Type

Method

Description

CompletableFuture<Integer>

executeAsync(JobExecutionContext ctx, Integer arg)

Executes the job on an Ignite node.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.ignite.compute.ComputeJob
inputMarshaller, resultMarshaller

Constructor Details
- IntegerDecrementJob
  
  public IntegerDecrementJob()
Method Details
- executeAsync
  
  public CompletableFuture<Integer> executeAsync(JobExecutionContext ctx, Integer arg)
  
  Description copied from interface: ComputeJob
  
  Executes the job on an Ignite node.
  
  Specified by:
  
  executeAsync in interface ComputeJob<Integer,Integer>
  
  Parameters:
  
  ctx - The execution context.
  
  arg - Job arguments.
  
  Returns:
  
  Job future. Can be null if the job is synchronous and does not return any result.