com.edmunds.rest.databricks

Class RunJob

java.lang.Object

com.edmunds.rest.databricks.RunJob

public class RunJob
extends Object

Run Job Class.

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_JOB_CHECK_INTERVAL
static long	DEFAULT_JOB_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
RunJob(JobService service, long jobId, RunParametersDTO runParametersDTO)
RunJob(JobService service, long jobId, RunParametersDTO runParametersDTO, long timeout, long checkInterval) Constructor.

Method Summary

Modifier and Type	Method and Description
void	cancelJob()
long	getCheckInterval()
long	getJobId()
long	getNumberInJob()
RunDTO	getRunDTO()
long	getRunId()
long	getTimeout()
RunNowDTO	launchJob() Launch the job on databricks.
RunResultStateDTO	process() Monitor the job.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_JOB_TIMEOUT

public static final long DEFAULT_JOB_TIMEOUT

DEFAULT_JOB_CHECK_INTERVAL

public static final long DEFAULT_JOB_CHECK_INTERVAL

Constructor Detail

RunJob

public RunJob(JobService service,
              long jobId,
              RunParametersDTO runParametersDTO)

RunJob

public RunJob(JobService service,
              long jobId,
              RunParametersDTO runParametersDTO,
              long timeout,
              long checkInterval)

Constructor.

Method Detail

process

public RunResultStateDTO process()
                          throws IOException,
                                 DatabricksRestException,
                                 InterruptedException

Monitor the job.

Returns:

throws DatabricksRestException if job do not succeed.

Throws:

IOException

DatabricksRestException

InterruptedException

launchJob

public RunNowDTO launchJob()
                    throws IOException,
                           DatabricksRestException

Launch the job on databricks.

Returns:

a RunNowDTO object.

Throws:

IOException

DatabricksRestException

getRunDTO

public RunDTO getRunDTO()
                 throws IOException,
                        DatabricksRestException

Throws:

IOException

DatabricksRestException

cancelJob

public void cancelJob()
               throws IOException,
                      DatabricksRestException

Throws:

IOException

DatabricksRestException

getJobId

public long getJobId()

getRunId

public long getRunId()

getNumberInJob

public long getNumberInJob()

getTimeout

public long getTimeout()

getCheckInterval

public long getCheckInterval()