org.apache.ignite.internal.processors.hadoop

Interface GridHadoop

public interface GridHadoop

Hadoop facade providing access to Ignite Hadoop features.

Method Summary

Methods

Modifier and Type	Method and Description
GridHadoopConfiguration	configuration() Gets Hadoop module configuration.
GridHadoopCounters	counters(GridHadoopJobId jobId) Returns job counters.
IgniteInternalFuture<?>	finishFuture(GridHadoopJobId jobId) Gets Hadoop finish future for particular job.
boolean	kill(GridHadoopJobId jobId) Kills job.
GridHadoopJobId	nextJobId() Generate next job ID.
GridHadoopJobStatus	status(GridHadoopJobId jobId) Gets Hadoop job execution status.
IgniteInternalFuture<?>	submit(GridHadoopJobId jobId, GridHadoopJobInfo jobInfo) Submits job to job tracker.

Method Detail

configuration

GridHadoopConfiguration configuration()

Gets Hadoop module configuration.

Returns:

Hadoop module configuration.

nextJobId

GridHadoopJobId nextJobId()

Generate next job ID.

Returns:

Next job ID.

submit

IgniteInternalFuture<?> submit(GridHadoopJobId jobId,
                             GridHadoopJobInfo jobInfo)

Submits job to job tracker.

Parameters:

jobId - Job ID to submit.

jobInfo - Job info to submit.

Returns:

Execution future.

status

@Nullable
GridHadoopJobStatus status(GridHadoopJobId jobId)
                           throws IgniteCheckedException

Gets Hadoop job execution status.

Parameters:

jobId - Job ID to get status for.

Returns:

Job execution status or null in case job with the given ID is not found.

Throws:

IgniteCheckedException - If failed.

counters

GridHadoopCounters counters(GridHadoopJobId jobId)
                            throws IgniteCheckedException

Returns job counters.

Parameters:

jobId - Job ID to get counters for.

Returns:

Job counters object.

Throws:

IgniteCheckedException - If failed.

finishFuture

@Nullable
IgniteInternalFuture<?> finishFuture(GridHadoopJobId jobId)
                                     throws IgniteCheckedException

Gets Hadoop finish future for particular job.

Parameters:

jobId - Job ID.

Returns:

Job finish future or null in case job with the given ID is not found.

Throws:

IgniteCheckedException - If failed.

kill

boolean kill(GridHadoopJobId jobId)
             throws IgniteCheckedException

Kills job.

Parameters:

jobId - Job ID.

Returns:

True if job was killed.

Throws:

IgniteCheckedException - If failed.