Package org.apache.ignite.example.compute

Class ComputePartitionQueryMapReduceExample.PartitionPersonCountJob

java.lang.Object

org.apache.ignite.example.compute.ComputePartitionQueryMapReduceExample.PartitionPersonCountJob

All Implemented Interfaces:

org.apache.ignite.compute.ComputeJob<Long,Long>

Enclosing class:

ComputePartitionQueryMapReduceExample

public static class ComputePartitionQueryMapReduceExample.PartitionPersonCountJob
extends Object
implements org.apache.ignite.compute.ComputeJob<Long,Long>

Job that counts persons in a single partition, identified by partition ID passed as the job argument.

The __PARTITION_ID virtual SQL column is used to filter rows to those belonging to the target partition. The partition ID is provided by ComputePartitionQueryMapReduceExample.PersonCountByPartitionTask during the split phase.

Constructor Summary

Constructors

Constructor	Description
PartitionPersonCountJob()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Long>	executeAsync(org.apache.ignite.compute.JobExecutionContext context, Long partitionId)

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

PartitionPersonCountJob

public PartitionPersonCountJob()

Method Details

executeAsync

public CompletableFuture<Long> executeAsync(org.apache.ignite.compute.JobExecutionContext context,
 Long partitionId)

Specified by:

executeAsync in interface org.apache.ignite.compute.ComputeJob<Long,Long>