Package org.apache.ignite.example.serialization

Class CustomPojoSerializationJob

java.lang.Object

org.apache.ignite.example.serialization.CustomPojoSerializationJob

All Implemented Interfaces:

ComputeJob<JsonArg,JsonResult>

public class CustomPojoSerializationJob
extends Object
implements ComputeJob<JsonArg,JsonResult>

Constructor Summary

Constructors

Constructor	Description
CustomPojoSerializationJob()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<JsonResult>	executeAsync(JobExecutionContext ctx, JsonArg arg)	Executes the job on an Ignite node.
Marshaller<JsonArg,byte[]>	inputMarshaller()	Marshaller for the input argument.
Marshaller<JsonResult,byte[]>	resultMarshaller()	Marshaller for the job result.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CustomPojoSerializationJob

public CustomPojoSerializationJob()

Method Details

executeAsync

public CompletableFuture<JsonResult> executeAsync(JobExecutionContext ctx,
 JsonArg arg)

Description copied from interface: ComputeJob

Executes the job on an Ignite node.

Specified by:

executeAsync in interface ComputeJob<JsonArg,JsonResult>

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.

inputMarshaller

public Marshaller<JsonArg,byte[]> inputMarshaller()

Description copied from interface: ComputeJob

Marshaller for the input argument. Default is null meaning that only primitive types are supported.

Specified by:

inputMarshaller in interface ComputeJob<JsonArg,JsonResult>

Returns:

Input marshaller.

resultMarshaller

public Marshaller<JsonResult,byte[]> resultMarshaller()

Description copied from interface: ComputeJob

Marshaller for the job result. Default is null meaning that only primitive types are supported.

Specified by:

resultMarshaller in interface ComputeJob<JsonArg,JsonResult>

Returns:

Result marshaller.