Package org.apache.ignite.example.compute
package org.apache.ignite.example.compute
-
ClassesClassDescriptionThis example demonstrates the usage of the
IgniteCompute.executeAsync(JobTarget, JobDescriptor, Object)API.This example demonstrates the usage of theIgniteCompute.execute(BroadcastJobTarget, JobDescriptor, Object)API.This example demonstrates the usage of theIgniteCompute.executeAsync(JobTarget, JobDescriptor, Object, CancellationToken)API.This example demonstrates the usage of theIgniteCompute.execute(JobTarget, JobDescriptor, Object)API with colocated JobTarget.This example demonstrates the usage of theIgniteCompute.execute(JobTarget, JobDescriptor, Object)API.This example demonstrates the usage of theIgniteCompute.execute(JobTarget, JobDescriptor, Object)API with different job priorities.This code demonstrates the usage of theJobExecutioninterface that allows to get job statuses and, for example, handle failures.This example demonstrates the usage of theIgniteCompute.executeMapReduce(TaskDescriptor, Object)API.MapReduce task that splits the input phrase into words and sends them to different nodes for the processing.This example demonstrates the usage of theIgniteCompute.execute(JobTarget, JobDescriptor, Object)API with a custom result marshaller.Job that calculates length of the provided word.The result object for the WordInfoJob.Marshals WordInfoResult into a byte array.This example demonstrates the usage of theIgniteCompute.execute(JobTarget, JobDescriptor, Object)API with a result return.