Package org.apache.ignite.example.serialization

Class PojoAutoSerializationJob

java.lang.Object

org.apache.ignite.example.serialization.PojoAutoSerializationJob

All Implemented Interfaces:

ComputeJob<AutoSerializableArg,AutoSerializableResult>

public class PojoAutoSerializationJob
extends Object
implements ComputeJob<AutoSerializableArg,AutoSerializableResult>

Constructor Summary

Constructors

Constructor	Description
PojoAutoSerializationJob()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<AutoSerializableResult>	executeAsync(JobExecutionContext ctx, AutoSerializableArg 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

PojoAutoSerializationJob

public PojoAutoSerializationJob()

Method Details

executeAsync

public CompletableFuture<AutoSerializableResult> executeAsync(JobExecutionContext ctx,
 AutoSerializableArg arg)

Description copied from interface: ComputeJob

Executes the job on an Ignite node.

Specified by:

executeAsync in interface ComputeJob<AutoSerializableArg,AutoSerializableResult>

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.