org.processmining.hadoop.common.algorithms

Class HadoopJob

java.lang.Object

org.processmining.hadoop.common.algorithms.HadoopJob

Direct Known Subclasses:

HybridMHadoopMiner

public abstract class HadoopJob
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	TIME_BETWEEN_CHECKS Time between checking if a job has ended in the asynchronous version

Constructor Summary

Constructors

Constructor and Description
HadoopJob()

Method Summary

Modifier and Type	Method and Description
protected static int	getCurrentJobStatus(RemoteConnectionManager ssh_manager, java.lang.String stderr_path) Returns the completed percentage of the map phase since it is the most time-consuming one
protected static boolean	isJobFinished(RemoteConnectionManager ssh_manager, java.lang.String pid) Return true if the job is finished.

Methods inherited from class java.lang.Object

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

Field Detail

TIME_BETWEEN_CHECKS

protected static final long TIME_BETWEEN_CHECKS

Time between checking if a job has ended in the asynchronous version

See Also:

Constant Field Values

Constructor Detail

HadoopJob

public HadoopJob()

Method Detail

getCurrentJobStatus

protected static int getCurrentJobStatus(RemoteConnectionManager ssh_manager,
                                         java.lang.String stderr_path)

Returns the completed percentage of the map phase since it is the most time-consuming one

Parameters:

ssh_manager - Connection manager able to check if the job has finished

stderr_path - Path to the stderr fail

Returns:

The percentage of the map phase (-1 if there is any error)

isJobFinished

protected static boolean isJobFinished(RemoteConnectionManager ssh_manager,
                                       java.lang.String pid)

Return true if the job is finished. False otherwise

Parameters:

ssh_manager - Connection manager able to check if the job has finished

job_pid - Pid of the job

Returns:

True if the job is finished. False otherwise.