org.apache.lens.server.scheduler

Class SchedulerDAO

java.lang.Object

org.apache.lens.server.scheduler.SchedulerDAO

public class SchedulerDAO
extends Object

SchedulerDAO class defines scheduler store operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SchedulerDAO.SchedulerDBStore
static class	SchedulerDAO.SchedulerHsqlDBStore HSQL Based DB store.
static class	SchedulerDAO.SchedulerMySQLDBStore MySQL based DB Store.

Constructor Summary

Constructors

Constructor and Description
SchedulerDAO(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
List<SchedulerJobInstanceRun>	getInstanceRuns(SchedulerJobInstanceState... states) Get all instances matching one of the states
XJob	getJob(SchedulerJobHandle id) Gets the job definition from the store
List<SchedulerJobHandle>	getJob(String jobName) Get the handle given the job name.
List<SchedulerJobInstanceInfo>	getJobInstances(SchedulerJobHandle id) Gets all the instance handle id for a job.
List<SchedulerJobHandle>	getJobs(String username, Long startTime, Long endTime, SchedulerJobState... jobStates) Gets all jobs which match the filter requirements.
SchedulerJobState	getJobState(SchedulerJobHandle id) Gets the Job status
SchedulerJobInfo	getSchedulerJobInfo(SchedulerJobHandle id) Fetches the SchedulerJobInfo object corresponding to handle id.
SchedulerJobInstanceInfo	getSchedulerJobInstanceInfo(SchedulerJobInstanceHandle id) Gets the SchedulerJobInstanceInfo corresponding instance handle id.
String	getUser(SchedulerJobHandle id) Get the user of the job who submitted the job.
int	storeJob(SchedulerJobInfo jobInfo) Saves the SchedulerJobInfo object into the store.
int	storeJobInstance(SchedulerJobInstanceInfo instanceInfo)
int	storeJobInstanceRun(SchedulerJobInstanceRun instanceRun)
int	updateJob(SchedulerJobInfo info) Updates the job definition from the new SchedulerJobInfo
int	updateJobInstanceRun(SchedulerJobInstanceRun instanceRun) Updates the instance status
int	updateJobStatus(SchedulerJobInfo info) Updates the job status form the new SchedulerJobInfo

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulerDAO

public SchedulerDAO(org.apache.hadoop.conf.Configuration conf)
             throws LensException

Throws:

LensException

Method Detail

storeJob

public int storeJob(SchedulerJobInfo jobInfo)

Saves the SchedulerJobInfo object into the store.

Parameters:

jobInfo - object

Returns:

the number of records stored

getSchedulerJobInfo

public SchedulerJobInfo getSchedulerJobInfo(SchedulerJobHandle id)

Fetches the SchedulerJobInfo object corresponding to handle id.

Parameters:

id: - Job handle id.

Returns:

SchedulerJobInfo

getJob

public XJob getJob(SchedulerJobHandle id)

Gets the job definition from the store

Parameters:

id - : Job handle id.

Returns:

XJob definition

getUser

public String getUser(SchedulerJobHandle id)

Get the user of the job who submitted the job.

Parameters:

id -

Returns:

getJobState

public SchedulerJobState getJobState(SchedulerJobHandle id)

Gets the Job status

Parameters:

id - : Job handle id.

Returns:

SchedulerJobStatus of the job.

updateJob

public int updateJob(SchedulerJobInfo info)

Updates the job definition from the new SchedulerJobInfo

Parameters:

info: - Updated info object.

Returns:

number of rows updated.

updateJobStatus

public int updateJobStatus(SchedulerJobInfo info)

Updates the job status form the new SchedulerJobInfo

Parameters:

info: - Updated info objects

Returns:

number of rows updated.

storeJobInstance

public int storeJobInstance(SchedulerJobInstanceInfo instanceInfo)

storeJobInstanceRun

public int storeJobInstanceRun(SchedulerJobInstanceRun instanceRun)

getSchedulerJobInstanceInfo

public SchedulerJobInstanceInfo getSchedulerJobInstanceInfo(SchedulerJobInstanceHandle id)

Gets the SchedulerJobInstanceInfo corresponding instance handle id.

Parameters:

id - : Job instance id

Returns:

ShedulerJobInstanceInfo

updateJobInstanceRun

public int updateJobInstanceRun(SchedulerJobInstanceRun instanceRun)

Updates the instance status

Parameters:

instanceRun - : instance Run object

Returns:

number of rows updated.

getJobInstances

public List<SchedulerJobInstanceInfo> getJobInstances(SchedulerJobHandle id)

Gets all the instance handle id for a job.

Parameters:

id: - Job handle id.

Returns:

List of instance handles.

getJobs

public List<SchedulerJobHandle> getJobs(String username,
                                        Long startTime,
                                        Long endTime,
                                        SchedulerJobState... jobStates)

Gets all jobs which match the filter requirements.

Parameters:

username - : User name of the job

startTime - : Created on should be greater than this start time.

endTime - : Created on should be less than the end time.

jobStates - : Multiple states of the jobs

Returns:

List of Job handles

getJob

public List<SchedulerJobHandle> getJob(String jobName)

Get the handle given the job name.

Parameters:

jobName -

Returns:

getInstanceRuns

public List<SchedulerJobInstanceRun> getInstanceRuns(SchedulerJobInstanceState... states)

Get all instances matching one of the states

Parameters:

states - States to be consider for filter

Returns:

A list of SchedulerJobInstanceRun