org.apache.ignite.internal.processors.hadoop

Class HadoopImpl

java.lang.Object

org.apache.ignite.internal.processors.hadoop.HadoopImpl

All Implemented Interfaces:

Hadoop

public class HadoopImpl
extends Object
implements Hadoop

Hadoop facade implementation.

Method Summary

Modifier and Type	Method and Description
HadoopConfiguration	configuration()
HadoopCounters	counters(HadoopJobId jobId)
IgniteInternalFuture<?>	finishFuture(HadoopJobId jobId)
boolean	kill(HadoopJobId jobId)
HadoopJobId	nextJobId()
HadoopJobStatus	status(HadoopJobId jobId)
IgniteInternalFuture<?>	submit(HadoopJobId jobId, HadoopJobInfo jobInfo)

Methods inherited from class java.lang.Object

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

Method Detail

configuration

public HadoopConfiguration configuration()

Specified by:

configuration in interface Hadoop

nextJobId

public HadoopJobId nextJobId()

Specified by:

nextJobId in interface Hadoop

submit

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

Specified by:

submit in interface Hadoop

status

@Nullable
public HadoopJobStatus status(HadoopJobId jobId)
                                 throws IgniteCheckedException

Specified by:

status in interface Hadoop

Throws:

IgniteCheckedException

counters

@Nullable
public HadoopCounters counters(HadoopJobId jobId)
                                  throws IgniteCheckedException

Specified by:

counters in interface Hadoop

Throws:

IgniteCheckedException

finishFuture

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

Specified by:

finishFuture in interface Hadoop

Throws:

IgniteCheckedException

kill

public boolean kill(HadoopJobId jobId)
             throws IgniteCheckedException

Specified by:

kill in interface Hadoop

Throws:

IgniteCheckedException