org.apache.ignite.internal.processors.hadoop

Class GridHadoopJobStatus

java.lang.Object

org.apache.ignite.internal.processors.hadoop.GridHadoopJobStatus

All Implemented Interfaces:

Externalizable, Serializable

public class GridHadoopJobStatus
extends Object
implements Externalizable

Hadoop job status.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridHadoopJobStatus() Externalizable support.
GridHadoopJobStatus(GridHadoopJobId jobId, String jobName, String usr, int pendingMapperCnt, int pendingReducerCnt, int totalMapperCnt, int totalReducerCnt, GridHadoopJobPhase jobPhase, boolean failed, long ver) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isFailed()
GridHadoopJobId	jobId()
String	jobName()
GridHadoopJobPhase	jobPhase()
int	pendingMapperCnt()
int	pendingReducerCnt()
void	readExternal(ObjectInput in)
String	toString()
int	totalMapperCnt()
int	totalReducerCnt()
String	user()
long	version()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

GridHadoopJobStatus

public GridHadoopJobStatus()

Externalizable support.

GridHadoopJobStatus

public GridHadoopJobStatus(GridHadoopJobId jobId,
                   String jobName,
                   String usr,
                   int pendingMapperCnt,
                   int pendingReducerCnt,
                   int totalMapperCnt,
                   int totalReducerCnt,
                   GridHadoopJobPhase jobPhase,
                   boolean failed,
                   long ver)

Constructor.

Parameters:

jobId - Job ID.

jobName - Job name.

usr - User.

pendingMapperCnt - Pending mappers count.

pendingReducerCnt - Pending reducers count.

totalMapperCnt - Total mappers count.

totalReducerCnt - Total reducers count.

jobPhase - Job phase.

failed - Failed.

ver - Version.

Method Detail

jobId

public GridHadoopJobId jobId()

Returns:

Job ID.

jobName

public String jobName()

Returns:

Job name.

user

public String user()

Returns:

User.

pendingMapperCnt

public int pendingMapperCnt()

Returns:

Pending mappers count.

pendingReducerCnt

public int pendingReducerCnt()

Returns:

Pending reducers count.

totalMapperCnt

public int totalMapperCnt()

Returns:

Total mappers count.

totalReducerCnt

public int totalReducerCnt()

Returns:

Total reducers count.

version

public long version()

Returns:

Version.

jobPhase

public GridHadoopJobPhase jobPhase()

Returns:

Job phase.

isFailed

public boolean isFailed()

Returns:

true If the job failed.

toString

public String toString()

Overrides:

toString in class Object

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException