org.apache.ignite.internal.processors.hadoop

Class HadoopProcessorAdapter

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.hadoop.HadoopProcessorAdapter

All Implemented Interfaces:

GridComponent, GridProcessor

Direct Known Subclasses:

HadoopNoopProcessor

public abstract class HadoopProcessorAdapter
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, diagnosticLog, log

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HadoopProcessorAdapter(GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
abstract HadoopConfiguration	config()
abstract HadoopCounters	counters(HadoopJobId jobId) Returns Hadoop job counters.
abstract IgniteInternalFuture<?>	finishFuture(HadoopJobId jobId) Gets Hadoop job finish future.
abstract Hadoop	hadoop()
abstract boolean	kill(HadoopJobId jobId) Kills job.
abstract HadoopJobId	nextJobId()
abstract HadoopJobStatus	status(HadoopJobId jobId) Gets Hadoop job execution status.
abstract IgniteInternalFuture<?>	submit(HadoopJobId jobId, HadoopJobInfo jobInfo) Submits job to job tracker.
abstract void	validateEnvironment() Validate Hadoop environment.

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

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onKernalStart, onKernalStop, onReconnected, printMemoryStats, start, stop, toString, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopProcessorAdapter

protected HadoopProcessorAdapter(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

hadoop

public abstract Hadoop hadoop()

Returns:

Hadoop facade.

config

public abstract HadoopConfiguration config()

Returns:

Hadoop configuration.

nextJobId

public abstract HadoopJobId nextJobId()

Returns:

Collection of generated IDs.

submit

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

public abstract HadoopJobStatus status(HadoopJobId 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 HadoopCounters counters(HadoopJobId 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(HadoopJobId 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(HadoopJobId jobId)
                      throws IgniteCheckedException

Kills job.

Parameters:

jobId - Job ID.

Returns:

True if job was killed.

Throws:

IgniteCheckedException - If failed.

validateEnvironment

public abstract void validateEnvironment()
                                  throws IgniteCheckedException

Validate Hadoop environment.

Throws:

IgniteCheckedException - If failed.