org.apache.ignite.internal.processors.hadoop

Class IgniteHadoopNoopProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

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

org.apache.ignite.internal.processors.hadoop.IgniteHadoopNoopProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class IgniteHadoopNoopProcessor
extends IgniteHadoopProcessorAdapter

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

Constructor and Description
IgniteHadoopNoopProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
GridHadoopConfiguration	config()
GridHadoopCounters	counters(GridHadoopJobId jobId) Returns Hadoop job counters.
IgniteInternalFuture<?>	finishFuture(GridHadoopJobId jobId) Gets Hadoop job finish future.
GridHadoop	hadoop()
boolean	kill(GridHadoopJobId jobId) Kills job.
GridHadoopJobId	nextJobId()
GridHadoopJobStatus	status(GridHadoopJobId jobId) Gets Hadoop job execution status.
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

IgniteHadoopNoopProcessor

public IgniteHadoopNoopProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

hadoop

public GridHadoop hadoop()

Specified by:

hadoop in class IgniteHadoopProcessorAdapter

Returns:

Hadoop facade.

config

public GridHadoopConfiguration config()

Specified by:

config in class IgniteHadoopProcessorAdapter

Returns:

Hadoop configuration.

nextJobId

public GridHadoopJobId nextJobId()

Specified by:

nextJobId in class IgniteHadoopProcessorAdapter

Returns:

Collection of generated IDs.

submit

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

Submits job to job tracker.

Specified by:

submit in class IgniteHadoopProcessorAdapter

Parameters:

jobId - Job ID to submit.

jobInfo - Job info to submit.

Returns:

Execution future.

status

public GridHadoopJobStatus status(GridHadoopJobId jobId)
                           throws IgniteCheckedException

Gets Hadoop job execution status.

Specified by:

status in class IgniteHadoopProcessorAdapter

Parameters:

jobId - Job ID to get status for.

Returns:

Job execution status.

Throws:

IgniteCheckedException - If failed.

counters

public GridHadoopCounters counters(GridHadoopJobId jobId)

Returns Hadoop job counters.

Specified by:

counters in class IgniteHadoopProcessorAdapter

Parameters:

jobId - Job ID to get counters for.

Returns:

Job counters.

finishFuture

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

Gets Hadoop job finish future.

Specified by:

finishFuture in class IgniteHadoopProcessorAdapter

Parameters:

jobId - Job ID.

Returns:

Job finish future or null.

Throws:

IgniteCheckedException - If failed.

kill

public boolean kill(GridHadoopJobId jobId)
             throws IgniteCheckedException

Kills job.

Specified by:

kill in class IgniteHadoopProcessorAdapter

Parameters:

jobId - Job ID.

Returns:

True if job was killed.

Throws:

IgniteCheckedException - If failed.