org.apache.lens.server.scheduler

Class SchedulerDAO.SchedulerDBStore

java.lang.Object

org.apache.lens.server.scheduler.SchedulerDAO.SchedulerDBStore

Direct Known Subclasses:

SchedulerDAO.SchedulerHsqlDBStore, SchedulerDAO.SchedulerMySQLDBStore

Enclosing class:

SchedulerDAO

public abstract static class SchedulerDAO.SchedulerDBStore
extends Object

Constructor Summary

Constructors

Constructor and Description
SchedulerDBStore()

Method Summary

Modifier and Type	Method and Description
abstract void	createJobInstanceRunTable() Creates the job instance run table
abstract void	createJobInstanceTable() Creates the job instance table
abstract void	createJobTable() Creates the job table
List<SchedulerJobInstanceInfo>	getAllJobInstances(String jobId) Gets all the instance handle of a job
List<SchedulerJobInstanceRun>	getInstanceRuns(SchedulerJobInstanceState[] states)
XJob	getJob(String id) Gets the job definition
SchedulerJobInstanceInfo	getJobInstanceInfo(String idStr) Gets the Job instance info corresponding to handle id.
List<SchedulerJobHandle>	getJobs(String username, SchedulerJobState[] states, Long starttime, Long endtime) Gets all the jobs which match the filter requirements.
List<SchedulerJobHandle>	getJobsByName(String jobname) Get the job handles given the job name
SchedulerJobState	getJobState(String id) Gets the job status
SchedulerJobInfo	getSchedulerJobInfo(String idStr) Gets the Job info object
String	getUser(String id) Get the user who submitted the job.
void	init(org.apache.commons.dbcp.BasicDataSource ds) Init the store.
int	insertIntoJobInstanceRunTable(SchedulerJobInstanceRun instanceRun)
int	insertIntoJobInstanceTable(SchedulerJobInstanceInfo instanceInfo) Inserts the job instance info object into job instance table
int	insertIntoJobTable(SchedulerJobInfo jobInfo) Inserts the Job info object into job table
int	updateJob(String id, XJob job, long modifiedOn) Update the XJob into the job table
int	updateJobInstanceRun(SchedulerJobInstanceRun instanceRun) Updates the status of a job instance.
int	updateJobStatus(String id, String status, long modifiedOn) Updates the job status into the job table

Methods inherited from class java.lang.Object

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

Constructor Detail

SchedulerDBStore

public SchedulerDBStore()

Method Detail

init

public void init(org.apache.commons.dbcp.BasicDataSource ds)

Init the store.

Parameters:

ds -

createJobTable

public abstract void createJobTable()
                             throws SQLException

Creates the job table

Throws:

SQLException

createJobInstanceTable

public abstract void createJobInstanceTable()
                                     throws SQLException

Creates the job instance table

Throws:

SQLException

createJobInstanceRunTable

public abstract void createJobInstanceRunTable()
                                        throws SQLException

Creates the job instance run table

Throws:

SQLException

insertIntoJobTable

public int insertIntoJobTable(SchedulerJobInfo jobInfo)
                       throws SQLException

Inserts the Job info object into job table

Parameters:

jobInfo -

Returns:

number of rows inserted.

Throws:

SQLException

insertIntoJobInstanceTable

public int insertIntoJobInstanceTable(SchedulerJobInstanceInfo instanceInfo)
                               throws SQLException

Inserts the job instance info object into job instance table

Parameters:

instanceInfo -

Returns:

number of rows inserted.

Throws:

SQLException

insertIntoJobInstanceRunTable

public int insertIntoJobInstanceRunTable(SchedulerJobInstanceRun instanceRun)
                                  throws SQLException

Throws:

SQLException

getSchedulerJobInfo

public SchedulerJobInfo getSchedulerJobInfo(String idStr)
                                     throws SQLException

Gets the Job info object

Parameters:

idStr -

Returns:

SchedulerJobInfo object corresponding to the job handle.

Throws:

SQLException

getJob

public XJob getJob(String id)
            throws SQLException

Gets the job definition

Parameters:

id -

Returns:

Xjob corresponding to the job handle

Throws:

SQLException

getJobsByName

public List<SchedulerJobHandle> getJobsByName(String jobname)
                                       throws SQLException

Get the job handles given the job name

Parameters:

jobname -

Returns:

A list of handles

Throws:

SQLException

getJobState

public SchedulerJobState getJobState(String id)
                              throws SQLException

Gets the job status

Parameters:

id -

Returns:

SchedulerJobStatus

Throws:

SQLException

getJobs

public List<SchedulerJobHandle> getJobs(String username,
                                        SchedulerJobState[] states,
                                        Long starttime,
                                        Long endtime)
                                 throws SQLException

Gets all the jobs which match the filter requirements.

Parameters:

username -

states -

starttime -

endtime -

Returns:

the list of job handles.

Throws:

SQLException

updateJob

public int updateJob(String id,
                     XJob job,
                     long modifiedOn)
              throws SQLException

Update the XJob into the job table

Parameters:

id -

job -

modifiedOn -

Returns:

the number of rows updated

Throws:

SQLException

updateJobStatus

public int updateJobStatus(String id,
                           String status,
                           long modifiedOn)
                    throws SQLException

Updates the job status into the job table

Parameters:

id -

status -

modifiedOn -

Returns:

number of rows updated.

Throws:

SQLException

getJobInstanceInfo

public SchedulerJobInstanceInfo getJobInstanceInfo(String idStr)
                                            throws SQLException

Gets the Job instance info corresponding to handle id.

Parameters:

idStr -

Returns:

SchedulerJobInstanceInfo

Throws:

SQLException

updateJobInstanceRun

public int updateJobInstanceRun(SchedulerJobInstanceRun instanceRun)
                         throws SQLException

Updates the status of a job instance.

Parameters:

instanceRun -

Returns:

number of rows updated.

Throws:

SQLException

getAllJobInstances

public List<SchedulerJobInstanceInfo> getAllJobInstances(String jobId)
                                                  throws SQLException

Gets all the instance handle of a job

Parameters:

jobId -

Returns:

List of SchedulerJobInstanceHandle

Throws:

SQLException

getUser

public String getUser(String id)
               throws SQLException

Get the user who submitted the job.

Parameters:

id -

Returns:

Throws:

SQLException

getInstanceRuns

public List<SchedulerJobInstanceRun> getInstanceRuns(SchedulerJobInstanceState[] states)
                                              throws SQLException

Throws:

SQLException