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

Class HadoopPrepareForJobRequest

java.lang.Object

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

All Implemented Interfaces:

Externalizable, Serializable, HadoopMessage

public class HadoopPrepareForJobRequest
extends Object
implements HadoopMessage

Child process initialization request.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopPrepareForJobRequest() Constructor required by Externalizable.
HadoopPrepareForJobRequest(HadoopJobId jobId, HadoopJobInfo jobInfo, int totalReducersCnt, int[] locReducers)

Method Summary

Modifier and Type	Method and Description
HadoopJobId	jobId()
HadoopJobInfo	jobInfo()
int[]	localReducers()
void	readExternal(ObjectInput in)
String	toString()
int	totalReducerCount()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopPrepareForJobRequest

public HadoopPrepareForJobRequest()

Constructor required by Externalizable.

HadoopPrepareForJobRequest

public HadoopPrepareForJobRequest(HadoopJobId jobId,
                                  HadoopJobInfo jobInfo,
                                  int totalReducersCnt,
                                  int[] locReducers)

Parameters:

jobId - Job ID.

jobInfo - Job info.

totalReducersCnt - Number of reducers in the job.

locReducers - Reducers to be executed on current node.

Method Detail

jobInfo

public HadoopJobInfo jobInfo()

Returns:

Job info.

jobId

public HadoopJobId jobId()

Returns:

Job ID.

localReducers

public int[] localReducers()

Returns:

Reducers to be executed on current node.

totalReducerCount

public int totalReducerCount()

Returns:

Number of reducers in job.

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