org.apache.ignite.internal.processors.hadoop

Interface Hadoop

public interface Hadoop

Hadoop facade providing access to Ignite Hadoop features.

Method Summary

Modifier and Type	Method and Description
HadoopConfiguration	configuration() Gets Hadoop module configuration.
HadoopCounters	counters(HadoopJobId jobId) Returns job counters.
@Nullable IgniteInternalFuture<?>	finishFuture(HadoopJobId jobId) Gets Hadoop finish future for particular job.
boolean	kill(HadoopJobId jobId) Kills job.
HadoopJobId	nextJobId() Generate next job ID.
@Nullable HadoopJobStatus	status(HadoopJobId jobId) Gets Hadoop job execution status.
IgniteInternalFuture<?>	submit(HadoopJobId jobId, HadoopJobInfo jobInfo) Submits job to job tracker.

Method Detail

configuration

HadoopConfiguration configuration()

Gets Hadoop module configuration.

Returns:

Hadoop module configuration.

nextJobId

HadoopJobId nextJobId()

Generate next job ID.

Returns:

Next job ID.

submit

IgniteInternalFuture<?> submit(HadoopJobId jobId,
                               HadoopJobInfo jobInfo)

Submits job to job tracker.

Parameters:

jobId - Job ID to submit.

jobInfo - Job info to submit.

Returns:

Execution future.

status

@Nullable
@Nullable HadoopJobStatus status(HadoopJobId 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

HadoopCounters counters(HadoopJobId jobId)
                 throws IgniteCheckedException

Returns job counters.

Parameters:

jobId - Job ID to get counters for.

Returns:

Job counters object.

Throws:

IgniteCheckedException - If failed.

finishFuture

@Nullable
@Nullable IgniteInternalFuture<?> finishFuture(HadoopJobId 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(HadoopJobId jobId)
      throws IgniteCheckedException

Kills job.

Parameters:

jobId - Job ID.

Returns:

True if job was killed.

Throws:

IgniteCheckedException - If failed.