org.apache.ignite.internal.processors.hadoop

Class HadoopProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

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

org.apache.ignite.internal.processors.hadoop.HadoopProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class HadoopProcessor
extends HadoopProcessorAdapter

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

Constructor and Description
HadoopProcessor(GridKernalContext ctx) Constructor.

Method Summary

Modifier and Type	Method and Description
HadoopConfiguration	config()
HadoopContext	context() Gets Hadoop context.
HadoopCounters	counters(HadoopJobId jobId)
IgniteInternalFuture<?>	finishFuture(HadoopJobId jobId)
Hadoop	hadoop()
boolean	kill(HadoopJobId jobId)
HadoopJobId	nextJobId()
void	onKernalStart(boolean active)
void	onKernalStop(boolean cancel)
void	start()
HadoopJobStatus	status(HadoopJobId jobId)
void	stop(boolean cancel)
IgniteInternalFuture<?>	submit(HadoopJobId jobId, HadoopJobInfo jobInfo)
String	toString()
void	validateEnvironment()

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

assertParameter, collectGridNodeData, collectJoiningNodeData, discoveryDataType, onDisconnected, onGridDataReceived, onJoiningNodeDataReceived, onReconnected, printMemoryStats, validateNode, validateNode

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopProcessor

public HadoopProcessor(GridKernalContext ctx)

Constructor.

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws IgniteCheckedException

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException

onKernalStart

public void onKernalStart(boolean active)
                   throws IgniteCheckedException

Specified by:

onKernalStart in interface GridComponent

Overrides:

onKernalStart in class GridProcessorAdapter

Throws:

IgniteCheckedException

onKernalStop

public void onKernalStop(boolean cancel)

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

stop

public void stop(boolean cancel)
          throws IgniteCheckedException

Specified by:

stop in interface GridComponent

Overrides:

stop in class GridProcessorAdapter

Throws:

IgniteCheckedException

context

public HadoopContext context()

Gets Hadoop context.

Returns:

Hadoop context.

hadoop

public Hadoop hadoop()

Specified by:

hadoop in class HadoopProcessorAdapter

config

public HadoopConfiguration config()

Specified by:

config in class HadoopProcessorAdapter

nextJobId

public HadoopJobId nextJobId()

Specified by:

nextJobId in class HadoopProcessorAdapter

submit

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

Specified by:

submit in class HadoopProcessorAdapter

status

public HadoopJobStatus status(HadoopJobId jobId)
                       throws IgniteCheckedException

Specified by:

status in class HadoopProcessorAdapter

Throws:

IgniteCheckedException

counters

public HadoopCounters counters(HadoopJobId jobId)
                        throws IgniteCheckedException

Specified by:

counters in class HadoopProcessorAdapter

Throws:

IgniteCheckedException

finishFuture

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

Specified by:

finishFuture in class HadoopProcessorAdapter

Throws:

IgniteCheckedException

kill

public boolean kill(HadoopJobId jobId)
             throws IgniteCheckedException

Specified by:

kill in class HadoopProcessorAdapter

Throws:

IgniteCheckedException

validateEnvironment

public void validateEnvironment()
                         throws IgniteCheckedException

Specified by:

validateEnvironment in class HadoopProcessorAdapter

Throws:

IgniteCheckedException

toString

public String toString()

Overrides:

toString in class GridProcessorAdapter