public class TaskSchedule extends Object implements AutoCloseable
TaskScheduleBuilder taskScheduleBuilder = TaskSchedule.builder(dataFlowOperations);
try (Task task = Task.builder(dataFlowOperations).name("myTask").definition("timestamp").build();
TaskSchedule taskSchedule = taskScheduleBuilder.scheduleName("mySchedule").task(task).build()) {
taskSchedule.schedule("56 20 ? * *", Collections.emptyMap());
TaskSchedule retrievedSchedule = taskScheduleBuilder.findByScheduleName(taskSchedule.getScheduleName());
taskSchedule.unschedule();
}
Modifier and Type | Field and Description |
---|---|
static String |
CRON_EXPRESSION_KEY |
Modifier and Type | Method and Description |
---|---|
static TaskScheduleBuilder |
builder(DataFlowOperations dataFlowOperations)
Fluent API method to create a
TaskScheduleBuilder . |
void |
close() |
String |
getScheduleName() |
Map<String,String> |
getScheduleProperties() |
Task |
getTask() |
boolean |
isScheduled() |
void |
schedule(String cronExpression,
Map<String,String> scheduleProperties,
String... taskArgs)
Schedule the task.
|
void |
unschedule()
Unschedule a previously scheduled task.
|
public static final String CRON_EXPRESSION_KEY
public static TaskScheduleBuilder builder(DataFlowOperations dataFlowOperations)
TaskScheduleBuilder
.dataFlowOperations
- DataFlowOperations
Data Flow Rest client instance.public void schedule(String cronExpression, Map<String,String> scheduleProperties, String... taskArgs)
scheduleProperties
- Scheduling properties to use.taskArgs
- task arguments to pass on schedule run.cronExpression
- the cron expression used to schedule the task execution.public void unschedule()
public boolean isScheduled()
public Map<String,String> getScheduleProperties()
public Task getTask()
public String getScheduleName()
public void close()
close
in interface AutoCloseable
Copyright © 2022 Pivotal Software, Inc.. All rights reserved.