Package | Description |
---|---|
org.apache.ambari.server.scheduler | |
org.apache.ambari.server.state | |
org.apache.ambari.server.state.cluster | |
org.apache.ambari.server.state.scheduler |
Modifier and Type | Method and Description |
---|---|
protected RequestStatus |
ExecutionScheduleManager.abortRequestById(RequestExecution requestExecution,
Long requestId) |
void |
ExecutionScheduleManager.deleteAllJobs(RequestExecution requestExecution)
Delete all jobs and triggers if possible.
|
void |
ExecutionScheduleManager.deleteJobs(RequestExecution requestExecution,
Long startingBatchOrderId)
Delete all jobs and triggers if possible.
|
void |
ExecutionScheduleManager.scheduleAllBatches(RequestExecution requestExecution)
Persist jobs based on the request batch and create trigger for the first
job
|
void |
ExecutionScheduleManager.scheduleBatch(RequestExecution requestExecution,
long startingBatchOrderId)
Persist jobs based on the request batches staring from the defined batch and create trigger for the first
job
|
void |
ExecutionScheduleManager.updateBatchSchedule(RequestExecution requestExecution)
Pause/resume/abort request schedule and related jobs and triggers
|
Modifier and Type | Method and Description |
---|---|
Map<Long,RequestExecution> |
Cluster.getAllRequestExecutions()
Get all @RequestExecution objects associated with the cluster
|
Modifier and Type | Method and Description |
---|---|
void |
Cluster.addRequestExecution(RequestExecution requestExecution)
Add a @RequestExecution to the cluster
|
Modifier and Type | Method and Description |
---|---|
Map<Long,RequestExecution> |
ClusterImpl.getAllRequestExecutions() |
Modifier and Type | Method and Description |
---|---|
void |
ClusterImpl.addRequestExecution(RequestExecution requestExecution) |
Modifier and Type | Class and Description |
---|---|
class |
RequestExecutionImpl |
Modifier and Type | Method and Description |
---|---|
RequestExecution |
RequestExecutionFactory.createExisting(Cluster cluster,
RequestScheduleEntity requestScheduleEntity) |
RequestExecution |
RequestExecutionFactory.createNew(Cluster cluster,
Batch batch,
Schedule schedule) |
Copyright © 2022 Apache Software Foundation. All rights reserved.