public class SchedulerService extends Object
Modifier and Type | Field and Description |
---|---|
protected org.pentaho.platform.api.scheduler2.IBlockoutManager |
blockoutManager |
protected FileService |
fileService |
protected org.pentaho.platform.api.engine.IAuthorizationPolicy |
policy |
protected org.pentaho.platform.api.repository2.unified.IUnifiedRepository |
repository |
protected org.pentaho.platform.api.scheduler2.IScheduler |
scheduler |
protected SessionResource |
sessionResource |
Constructor and Description |
---|
SchedulerService() |
Modifier and Type | Method and Description |
---|---|
org.pentaho.platform.api.scheduler2.Job |
addBlockout(JobScheduleRequest jobScheduleRequest) |
protected Boolean |
canAdminister() |
protected Boolean |
canAdminister(org.pentaho.platform.api.engine.IPentahoSession session) |
protected org.pentaho.platform.api.scheduler2.IJobTrigger |
convertScheduleRequestToJobTrigger(JobScheduleRequest jobScheduleRequest) |
org.pentaho.platform.api.scheduler2.Job |
createJob(JobScheduleRequest scheduleRequest) |
String |
doGetCanSchedule() |
List<org.pentaho.platform.api.repository2.unified.webservices.RepositoryFileDto> |
doGetGeneratedContentForSchedule(String lineageId) |
Class<org.pentaho.platform.api.action.IAction> |
getAction(String actionClass) |
String |
getAppendDateFormat(JobScheduleRequest scheduleRequest) |
boolean |
getAutoCreateUniqueFilename(JobScheduleRequest scheduleRequest) |
List<org.pentaho.platform.api.scheduler2.Job> |
getBlockOutJobs() |
protected org.pentaho.platform.api.scheduler2.IBlockoutManager |
getBlockoutManager() |
BlockStatusProxy |
getBlockStatus(JobScheduleRequest jobScheduleRequest) |
protected BlockStatusProxy |
getBlockStatusProxy(Boolean totallyBlocked,
Boolean partiallyBlocked) |
org.pentaho.platform.api.scheduler2.Job |
getContentCleanerJob() |
protected String |
getExtension(String filename) |
protected FileService |
getFileService() |
org.pentaho.platform.api.scheduler2.Job |
getJob(String jobId) |
org.pentaho.platform.api.scheduler2.IJobFilter |
getJobFilter(boolean canAdminister,
String principalName) |
JobScheduleRequest |
getJobInfo() |
org.pentaho.platform.api.scheduler2.Job |
getJobInfo(String jobId) |
List<org.pentaho.platform.api.scheduler2.Job> |
getJobs() |
protected JobScheduleParam |
getJobScheduleParam(String name,
long value) |
protected JobScheduleParam |
getJobScheduleParam(String name,
String value) |
org.pentaho.platform.api.scheduler2.Job.JobState |
getJobState(JobRequest jobRequest) |
org.pentaho.platform.api.engine.IAuthorizationPolicy |
getPolicy() |
org.pentaho.platform.api.repository2.unified.IUnifiedRepository |
getRepository() |
org.pentaho.platform.api.scheduler2.IScheduler |
getScheduler() |
protected SchedulerOutputPathResolver |
getSchedulerOutputPathResolver(JobScheduleRequest scheduleRequest) |
protected org.pentaho.platform.api.engine.ISecurityHelper |
getSecurityHelper() |
protected org.pentaho.platform.api.engine.IPentahoSession |
getSession() |
protected SessionResource |
getSessionResource()
Gets an instance of SessionResource
|
String |
getState() |
protected HashMap<String,Serializable> |
handlePDIScheduling(org.pentaho.platform.api.repository2.unified.RepositoryFile file,
HashMap<String,Serializable> parameterMap,
Map<String,String> pdiParameters) |
boolean |
hasBlockouts() |
protected boolean |
isPdiFile(org.pentaho.platform.api.repository2.unified.RepositoryFile file) |
boolean |
isScheduleAllowed() |
boolean |
isScheduleAllowed(String id) |
String |
pause() |
org.pentaho.platform.api.scheduler2.Job.JobState |
pauseJob(String jobId) |
boolean |
removeJob(String jobId) |
protected String |
resolveActionId(String inputFile) |
org.pentaho.platform.api.scheduler2.Job.JobState |
resumeJob(String jobId) |
boolean |
shouldFireNow() |
String |
shutdown() |
String |
start() |
org.pentaho.platform.api.scheduler2.Job |
triggerNow(String jobId) |
org.pentaho.platform.api.scheduler2.Job |
updateBlockout(String jobId,
JobScheduleRequest jobScheduleRequest) |
org.pentaho.platform.api.scheduler2.Job |
updateJob(JobScheduleRequest scheduleRequest) |
protected void |
updateStartDateForTimeZone(JobScheduleRequest jobScheduleRequest) |
boolean |
willFire(org.pentaho.platform.api.scheduler2.IJobTrigger trigger) |
protected org.pentaho.platform.api.scheduler2.IScheduler scheduler
protected org.pentaho.platform.api.engine.IAuthorizationPolicy policy
protected org.pentaho.platform.api.repository2.unified.IUnifiedRepository repository
protected SessionResource sessionResource
protected FileService fileService
protected org.pentaho.platform.api.scheduler2.IBlockoutManager blockoutManager
public org.pentaho.platform.api.scheduler2.Job createJob(JobScheduleRequest scheduleRequest) throws IOException, org.pentaho.platform.api.scheduler2.SchedulerException, IllegalAccessException
IOException
org.pentaho.platform.api.scheduler2.SchedulerException
IllegalAccessException
public org.pentaho.platform.api.scheduler2.Job updateJob(JobScheduleRequest scheduleRequest) throws IllegalAccessException, IOException, org.pentaho.platform.api.scheduler2.SchedulerException
IllegalAccessException
IOException
org.pentaho.platform.api.scheduler2.SchedulerException
public org.pentaho.platform.api.scheduler2.Job triggerNow(String jobId) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public org.pentaho.platform.api.scheduler2.Job getContentCleanerJob() throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public List<org.pentaho.platform.api.repository2.unified.webservices.RepositoryFileDto> doGetGeneratedContentForSchedule(String lineageId) throws FileNotFoundException
lineageId
- FileNotFoundException
public org.pentaho.platform.api.scheduler2.Job getJob(String jobId) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public boolean isScheduleAllowed()
public boolean isScheduleAllowed(String id)
public org.pentaho.platform.api.scheduler2.IJobFilter getJobFilter(boolean canAdminister, String principalName)
public String doGetCanSchedule()
public String getState() throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public String start() throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public String pause() throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public String shutdown() throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public org.pentaho.platform.api.scheduler2.Job.JobState pauseJob(String jobId) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public org.pentaho.platform.api.scheduler2.Job.JobState resumeJob(String jobId) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public boolean removeJob(String jobId) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public org.pentaho.platform.api.scheduler2.Job getJobInfo(String jobId) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public List<org.pentaho.platform.api.scheduler2.Job> getBlockOutJobs()
public boolean hasBlockouts()
public boolean willFire(org.pentaho.platform.api.scheduler2.IJobTrigger trigger)
public boolean shouldFireNow()
public org.pentaho.platform.api.scheduler2.Job addBlockout(JobScheduleRequest jobScheduleRequest) throws IOException, IllegalAccessException, org.pentaho.platform.api.scheduler2.SchedulerException
IOException
IllegalAccessException
org.pentaho.platform.api.scheduler2.SchedulerException
protected JobScheduleParam getJobScheduleParam(String name, String value)
protected JobScheduleParam getJobScheduleParam(String name, long value)
protected void updateStartDateForTimeZone(JobScheduleRequest jobScheduleRequest)
public org.pentaho.platform.api.scheduler2.Job updateBlockout(String jobId, JobScheduleRequest jobScheduleRequest) throws IllegalAccessException, org.pentaho.platform.api.scheduler2.SchedulerException, IOException
IllegalAccessException
org.pentaho.platform.api.scheduler2.SchedulerException
IOException
public BlockStatusProxy getBlockStatus(JobScheduleRequest jobScheduleRequest) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
protected BlockStatusProxy getBlockStatusProxy(Boolean totallyBlocked, Boolean partiallyBlocked)
protected org.pentaho.platform.api.scheduler2.IJobTrigger convertScheduleRequestToJobTrigger(JobScheduleRequest jobScheduleRequest) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
public JobScheduleRequest getJobInfo()
public org.pentaho.platform.api.scheduler2.Job.JobState getJobState(JobRequest jobRequest) throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
protected org.pentaho.platform.api.engine.IPentahoSession getSession()
public Class<org.pentaho.platform.api.action.IAction> getAction(String actionClass) throws ClassNotFoundException
ClassNotFoundException
public org.pentaho.platform.api.repository2.unified.IUnifiedRepository getRepository()
public org.pentaho.platform.api.scheduler2.IScheduler getScheduler()
public org.pentaho.platform.api.engine.IAuthorizationPolicy getPolicy()
protected SchedulerOutputPathResolver getSchedulerOutputPathResolver(JobScheduleRequest scheduleRequest)
protected boolean isPdiFile(org.pentaho.platform.api.repository2.unified.RepositoryFile file)
protected HashMap<String,Serializable> handlePDIScheduling(org.pentaho.platform.api.repository2.unified.RepositoryFile file, HashMap<String,Serializable> parameterMap, Map<String,String> pdiParameters)
public boolean getAutoCreateUniqueFilename(JobScheduleRequest scheduleRequest)
public String getAppendDateFormat(JobScheduleRequest scheduleRequest)
public List<org.pentaho.platform.api.scheduler2.Job> getJobs() throws org.pentaho.platform.api.scheduler2.SchedulerException
org.pentaho.platform.api.scheduler2.SchedulerException
protected Boolean canAdminister()
protected Boolean canAdminister(org.pentaho.platform.api.engine.IPentahoSession session)
protected SessionResource getSessionResource()
SessionResource
protected FileService getFileService()
protected org.pentaho.platform.api.scheduler2.IBlockoutManager getBlockoutManager()
protected org.pentaho.platform.api.engine.ISecurityHelper getSecurityHelper()
Copyright © 2019 Hitachi Vantara. All rights reserved.