org.apache.ignite.internal.processors.hadoop

Class IgniteHadoopProcessorAdapter

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.hadoop.IgniteHadoopProcessorAdapter

All Implemented Interfaces:

GridComponent, GridProcessor

Direct Known Subclasses:

IgniteHadoopNoopProcessor

public abstract class IgniteHadoopProcessorAdapter
extends GridProcessorAdapter

Hadoop processor.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	IgniteHadoopProcessorAdapter(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
abstract GridHadoopConfiguration	config()
abstract GridHadoopCounters	counters(GridHadoopJobId jobId) Returns Hadoop job counters.
abstract IgniteInternalFuture<?>	finishFuture(GridHadoopJobId jobId) Gets Hadoop job finish future.
abstract GridHadoop	hadoop()
abstract boolean	kill(GridHadoopJobId jobId) Kills job.
abstract GridHadoopJobId	nextJobId()
abstract GridHadoopJobStatus	status(GridHadoopJobId jobId) Gets Hadoop job execution status.
abstract IgniteInternalFuture<?>	submit(GridHadoopJobId jobId, GridHadoopJobInfo jobInfo) Submits job to job tracker.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

addAttributes, assertParameter, collectDiscoveryData, discoveryDataType, onDiscoveryDataReceived, onKernalStart, onKernalStop, printMemoryStats, start, stop, toString, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

IgniteHadoopProcessorAdapter

protected IgniteHadoopProcessorAdapter(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

hadoop

public abstract GridHadoop hadoop()

Returns:

Hadoop facade.

config

public abstract GridHadoopConfiguration config()

Returns:

Hadoop configuration.

nextJobId

public abstract GridHadoopJobId nextJobId()

Returns:

Collection of generated IDs.

submit

public abstract 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

public abstract GridHadoopJobStatus status(GridHadoopJobId jobId)
                                    throws IgniteCheckedException

Gets Hadoop job execution status.

Parameters:

jobId - Job ID to get status for.

Returns:

Job execution status.

Throws:

IgniteCheckedException - If failed.

counters

public abstract GridHadoopCounters counters(GridHadoopJobId jobId)
                                     throws IgniteCheckedException

Returns Hadoop job counters.

Parameters:

jobId - Job ID to get counters for.

Returns:

Job counters.

Throws:

IgniteCheckedException - If failed.

finishFuture

public abstract IgniteInternalFuture<?> finishFuture(GridHadoopJobId jobId)
                                              throws IgniteCheckedException

Gets Hadoop job finish future.

Parameters:

jobId - Job ID.

Returns:

Job finish future or null.

Throws:

IgniteCheckedException - If failed.

kill

public abstract boolean kill(GridHadoopJobId jobId)
                      throws IgniteCheckedException

Kills job.

Parameters:

jobId - Job ID.

Returns:

True if job was killed.

Throws:

IgniteCheckedException - If failed.