org.apache.ignite.internal.processors.hadoop.jobtracker

Class HadoopJobMetadata

java.lang.Object

org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata

All Implemented Interfaces:

Externalizable, Serializable

public class HadoopJobMetadata
extends Object
implements Externalizable

Hadoop job metadata. Internal object used for distributed job state tracking.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopJobMetadata() Empty constructor required by Externalizable.
HadoopJobMetadata(HadoopJobMetadata src) Copy constructor.
HadoopJobMetadata(UUID submitNodeId, HadoopJobId jobId, HadoopJobInfo jobInfo) Constructor.

Method Summary

Modifier and Type	Method and Description
HadoopCounters	counters() Returns job counters.
void	counters(HadoopCounters counters) Sets counters.
Throwable	failCause()
void	failCause(Throwable failCause)
HadoopJobId	jobId()
HadoopJobInfo	jobInfo()
HadoopMapReducePlan	mapReducePlan()
void	mapReducePlan(HadoopMapReducePlan mrPlan)
Collection<Integer>	pendingReducers() Gets collection of pending reducers.
void	pendingReducers(Collection<Integer> pendingReducers) Sets collection of pending reducers.
Map<HadoopInputSplit,Integer>	pendingSplits() Gets collection of pending splits.
void	pendingSplits(Map<HadoopInputSplit,Integer> pendingSplits) Sets collection of pending splits.
HadoopJobPhase	phase()
void	phase(HadoopJobPhase phase)
void	readExternal(ObjectInput in)
Map<Integer,HadoopProcessDescriptor>	reducersAddresses() Gets reducers addresses for external execution.
void	reducersAddresses(Map<Integer,HadoopProcessDescriptor> reducersAddrs) Sets reducers addresses for external execution.
UUID	submitNodeId()
int	taskNumber(HadoopInputSplit split)
String	toString()
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

HadoopJobMetadata

public HadoopJobMetadata()

Empty constructor required by Externalizable.

HadoopJobMetadata

public HadoopJobMetadata(UUID submitNodeId,
                         HadoopJobId jobId,
                         HadoopJobInfo jobInfo)

Constructor.

Parameters:

submitNodeId - Submit node ID.

jobId - Job ID.

jobInfo - Job info.

HadoopJobMetadata

public HadoopJobMetadata(HadoopJobMetadata src)

Copy constructor.

Parameters:

src - Metadata to copy.

Method Detail

submitNodeId

public UUID submitNodeId()

Returns:

Submit node ID.

phase

public void phase(HadoopJobPhase phase)

Parameters:

phase - Job phase.

phase

public HadoopJobPhase phase()

Returns:

Job phase.

reducersAddresses

public Map<Integer,HadoopProcessDescriptor> reducersAddresses()

Gets reducers addresses for external execution.

Returns:

Reducers addresses.

reducersAddresses

public void reducersAddresses(Map<Integer,HadoopProcessDescriptor> reducersAddrs)

Sets reducers addresses for external execution.

Parameters:

reducersAddrs - Map of addresses.

pendingSplits

public void pendingSplits(Map<HadoopInputSplit,Integer> pendingSplits)

Sets collection of pending splits.

Parameters:

pendingSplits - Collection of pending splits.

pendingSplits

public Map<HadoopInputSplit,Integer> pendingSplits()

Gets collection of pending splits.

Returns:

Collection of pending splits.

pendingReducers

public void pendingReducers(Collection<Integer> pendingReducers)

Sets collection of pending reducers.

Parameters:

pendingReducers - Collection of pending reducers.

pendingReducers

public Collection<Integer> pendingReducers()

Gets collection of pending reducers.

Returns:

Collection of pending reducers.

jobId

public HadoopJobId jobId()

Returns:

Job ID.

mapReducePlan

public void mapReducePlan(HadoopMapReducePlan mrPlan)

Parameters:

mrPlan - Map-reduce plan.

mapReducePlan

public HadoopMapReducePlan mapReducePlan()

Returns:

Map-reduce plan.

jobInfo

public HadoopJobInfo jobInfo()

Returns:

Job info.

counters

public HadoopCounters counters()

Returns job counters.

Returns:

Collection of counters.

counters

public void counters(HadoopCounters counters)

Sets counters.

Parameters:

counters - Collection of counters.

failCause

public void failCause(Throwable failCause)

Parameters:

failCause - Fail cause.

failCause

public Throwable failCause()

Returns:

Fail cause.

version

public long version()

Returns:

Version.

taskNumber

public int taskNumber(HadoopInputSplit split)

Parameters:

split - Split.

Returns:

Task number.

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