org.apache.ignite.internal.visor.consistency

Class VisorConsistencyStatusTask

java.lang.Object

org.apache.ignite.internal.visor.VisorMultiNodeTask<A,VisorConsistencyTaskResult,J>

org.apache.ignite.internal.visor.consistency.AbstractConsistencyTask<Void,String>

org.apache.ignite.internal.visor.consistency.VisorConsistencyStatusTask

All Implemented Interfaces:

Serializable, ComputeTask<VisorTaskArgument<Void>,VisorConsistencyTaskResult>

public class VisorConsistencyStatusTask
extends AbstractConsistencyTask<Void,String>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static ConcurrentHashMap<String,String>	MAP Status map.
static String	NOTHING_FOUND Nothing found.

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

debug, ignite, start, taskArg

Constructor Summary

Constructors

Constructor and Description
VisorConsistencyStatusTask()

Method Summary

Modifier and Type	Method and Description
protected VisorJob<Void,String>	job(Void arg)
protected VisorConsistencyTaskResult	reduce0(List<ComputeJobResult> results) 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

Field Detail

NOTHING_FOUND

public static final String NOTHING_FOUND

Nothing found.

See Also:

Constant Field Values

MAP

public static final ConcurrentHashMap<String,String> MAP

Status map.

Constructor Detail

VisorConsistencyStatusTask

public VisorConsistencyStatusTask()

Method Detail

job

protected VisorJob<Void,String> job(Void arg)

Specified by:

job in class VisorMultiNodeTask<Void,VisorConsistencyTaskResult,String>

Parameters:

arg - Task arg.

Returns:

New job.

reduce0

protected VisorConsistencyTaskResult reduce0(List<ComputeJobResult> results)
                                      throws IgniteException

Actual reduce logic.

Overrides:

reduce0 in class AbstractConsistencyTask<Void,String>

Parameters:

results - Job results.

Returns:

Task result.

Throws:

IgniteException - If reduction or results caused an error.