Package org.apache.ignite.internal.commandline.cache.distribution

Class CacheDistributionTask

java.lang.Object

org.apache.ignite.internal.visor.VisorMultiNodeTask<CacheDistributionCommandArg,CacheDistributionTaskResult,CacheDistributionNode>

org.apache.ignite.internal.commandline.cache.distribution.CacheDistributionTask

All Implemented Interfaces:

Serializable, ComputeTask<VisorTaskArgument<CacheDistributionCommandArg>,VisorTaskResult<CacheDistributionTaskResult>>

public class CacheDistributionTask
extends VisorMultiNodeTask<CacheDistributionCommandArg,CacheDistributionTaskResult,CacheDistributionNode>

Collect information on the distribution of partitions.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.ignite.internal.visor.VisorMultiNodeTask

debug, ignite, start, taskArg

Constructor Summary

Constructors

Constructor	Description
CacheDistributionTask()

Method Summary

Modifier and Type	Method	Description
protected VisorJob<CacheDistributionCommandArg,CacheDistributionNode>	job(CacheDistributionCommandArg arg)
protected @Nullable CacheDistributionTaskResult	reduce0(List<ComputeJobResult> list)	Actual reduce logic.

Methods inherited from class org.apache.ignite.internal.visor.VisorMultiNodeTask

jobNodes, map, map0, reduce, result

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheDistributionTask

public CacheDistributionTask()

Method Detail

reduce0

@Nullable
protected @Nullable CacheDistributionTaskResult reduce0(List<ComputeJobResult> list)
                                                 throws IgniteException

Actual reduce logic.

Specified by:

reduce0 in class VisorMultiNodeTask<CacheDistributionCommandArg,CacheDistributionTaskResult,CacheDistributionNode>

Parameters:

list - Job results.

Returns:

Task result.

Throws:

IgniteException - If reduction or results caused an error.

job

protected VisorJob<CacheDistributionCommandArg,CacheDistributionNode> job(CacheDistributionCommandArg arg)

Specified by:

job in class VisorMultiNodeTask<CacheDistributionCommandArg,CacheDistributionTaskResult,CacheDistributionNode>

Parameters:

arg - Task arg.

Returns:

New job.