org.apache.ignite.internal.jdbc

Class JdbcConnectionValidationTask

java.lang.Object

org.apache.ignite.compute.ComputeTaskAdapter<T,R>

org.apache.ignite.compute.ComputeTaskSplitAdapter<Object,Boolean>

org.apache.ignite.internal.jdbc.JdbcConnectionValidationTask

All Implemented Interfaces:

Serializable, ComputeTask<Object,Boolean>

Deprecated.

Using Ignite client node based JDBC driver is preferable. See documentation of IgniteJdbcDriver for details.

@Deprecated
public class JdbcConnectionValidationTask
extends ComputeTaskSplitAdapter<Object,Boolean>

This task is used for JdbcConnection validation.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JdbcConnectionValidationTask() Deprecated.

Method Summary

Modifier and Type	Method and Description
@Nullable Boolean	reduce(List<ComputeJobResult> results) Deprecated. Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
protected Collection<? extends ComputeJob>	split(int gridSize, Object arg) Deprecated. This is a simplified version of ComputeTask.map(List, Object) method.

Methods inherited from class org.apache.ignite.compute.ComputeTaskSplitAdapter

map

Methods inherited from class org.apache.ignite.compute.ComputeTaskAdapter

result

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcConnectionValidationTask

public JdbcConnectionValidationTask()

Deprecated.

Method Detail

split

protected Collection<? extends ComputeJob> split(int gridSize,
                                                 Object arg)
                                          throws IgniteException

Deprecated.

This is a simplified version of ComputeTask.map(List, Object) method.

This method basically takes given argument and splits it into a collection of ComputeJob using provided grid size as indication of how many node are available. These jobs will be randomly mapped to available grid nodes. Note that if number of jobs is greater than number of grid nodes (i.e, grid size), the grid nodes will be reused and some jobs will end up on the same grid nodes.

Specified by:

split in class ComputeTaskSplitAdapter<Object,Boolean>

Parameters:

gridSize - Number of available grid nodes. Note that returned number of jobs can be less, equal or greater than this grid size.

arg - Task execution argument. Can be null.

Returns:

Collection of grid jobs. These jobs will be randomly mapped to available grid nodes. Note that if number of jobs is greater than number of grid nodes (i.e, grid size), the grid nodes will be reused and some jobs will end up on the same grid nodes.

Throws:

IgniteException - Thrown in case of any errors.

See Also:

ComputeTask.map(List, Object)

reduce

@Nullable
public @Nullable Boolean reduce(List<ComputeJobResult> results)
                                   throws IgniteException

Deprecated.

Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.

Note, that if some jobs did not succeed and could not be failed over then the list of results passed into this method will include the failed results. Otherwise, failed results will not be in the list.

Parameters:

results - Received results of broadcasted remote executions. Note that if task class has ComputeTaskNoResultCache annotation, then this list will be empty.

Returns:

Grid job result constructed from results of remote executions.

Throws:

IgniteException - If reduction or results caused an error. This exception will be thrown out of ComputeTaskFuture.get() method.