MyJob

java.lang.Object

org.apache.ignite.example.code.deployment.MyJob

All Implemented Interfaces:: ComputeJob<String,String>

public class MyJob extends Object implements ComputeJob<String,String>

Constructor Summary

Constructors

Constructor

Description

MyJob()
Method Summary

Modifier and Type

Method

Description

CompletableFuture<String>

executeAsync(JobExecutionContext ctx, String 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
- MyJob
  
  public MyJob()
Method Details
- executeAsync
  
  public CompletableFuture<String> executeAsync(JobExecutionContext ctx, String arg)
  
  Description copied from interface: ComputeJob
  
  Executes the job on an Ignite node.
  
  Specified by:
  
  executeAsync in interface ComputeJob<String,String>
  
  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.