org.apache.ignite.internal.processors.hadoop.taskexecutor.external

Class HadoopJobInfoUpdateRequest

java.lang.Object

org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest

All Implemented Interfaces:

Externalizable, Serializable, HadoopMessage

public class HadoopJobInfoUpdateRequest
extends Object
implements HadoopMessage

Job info update request.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopJobInfoUpdateRequest() Constructor required by Externalizable.
HadoopJobInfoUpdateRequest(HadoopJobId jobId, HadoopJobPhase jobPhase, HadoopProcessDescriptor[] reducersAddrs)

Method Summary

Modifier and Type	Method and Description
HadoopJobId	jobId()
HadoopJobPhase	jobPhase()
void	readExternal(ObjectInput in)
HadoopProcessDescriptor[]	reducersAddresses()
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopJobInfoUpdateRequest

public HadoopJobInfoUpdateRequest()

Constructor required by Externalizable.

HadoopJobInfoUpdateRequest

public HadoopJobInfoUpdateRequest(HadoopJobId jobId,
                                  HadoopJobPhase jobPhase,
                                  HadoopProcessDescriptor[] reducersAddrs)

Parameters:

jobId - Job ID.

jobPhase - Job phase.

reducersAddrs - Reducers addresses.

Method Detail

jobId

public HadoopJobId jobId()

Returns:

Job ID.

jobPhase

public HadoopJobPhase jobPhase()

Returns:

Job phase.

reducersAddresses

public HadoopProcessDescriptor[] reducersAddresses()

Returns:

Reducers addresses.

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

toString

public String toString()

Overrides:

toString in class Object