| Modifier and Type | Method and Description |
|---|---|
boolean |
JdbcDelegate.deleteJob(java.lang.String jobid,
java.lang.String nodeId) |
boolean |
DatabaseDelegate.deleteJob(java.lang.String jobid,
java.lang.String nodeId)
Delete a job from the database.
|
java.util.List<org.apache.ode.scheduler.simple.Job> |
JdbcDelegate.dequeueImmediate(java.lang.String nodeId,
long maxtime,
int maxjobs) |
java.util.List<org.apache.ode.scheduler.simple.Job> |
DatabaseDelegate.dequeueImmediate(java.lang.String nodeId,
long maxtime,
int maxjobs)
"Dequeue" jobs from the database that are ready for immediate execution; this basically
is a select/delete operation with constraints on the nodeId and scheduled time.
|
java.util.List<java.lang.String> |
JdbcDelegate.getNodeIds() |
java.util.List<java.lang.String> |
DatabaseDelegate.getNodeIds()
Return a list of unique nodes identifiers found in the database.
|
boolean |
JdbcDelegate.insertJob(org.apache.ode.scheduler.simple.Job job,
java.lang.String nodeId,
boolean loaded) |
boolean |
DatabaseDelegate.insertJob(org.apache.ode.scheduler.simple.Job job,
java.lang.String nodeId,
boolean loaded)
Save the job in the database.
|
boolean |
JdbcDelegate.insertNode(java.lang.String nodeId,
long heartbeat,
java.lang.String leaderNodeId) |
boolean |
DatabaseDelegate.insertNode(java.lang.String nodeId,
long heartbeat,
java.lang.String leaderNodeId) |
boolean |
JdbcDelegate.removeNode(java.lang.String nodeId) |
boolean |
DatabaseDelegate.removeNode(java.lang.String nodeId) |
java.util.List<Node> |
JdbcDelegate.retrieveClusterNodes(java.lang.String clusterLeaderNode) |
java.util.List<Node> |
DatabaseDelegate.retrieveClusterNodes(java.lang.String leaderNode) |
int |
JdbcDelegate.updateAssignToNode(java.lang.String node,
int i,
int numNodes,
long maxtime) |
int |
DatabaseDelegate.updateAssignToNode(java.lang.String nodeId,
int x,
int y,
long maxtime)
Assign a particular node identifier to a fraction of jobs in the database that do not have one,
and are up for execution within a certain time.
|
boolean |
JdbcDelegate.updateJob(org.apache.ode.scheduler.simple.Job job) |
boolean |
DatabaseDelegate.updateJob(org.apache.ode.scheduler.simple.Job job)
Update the job in the database (only updates timestamp and retryCount)
|
boolean |
JdbcDelegate.updateNodeHeartbeat(java.lang.String nodeId,
long heartbeat,
java.lang.String leaderNodeId) |
boolean |
DatabaseDelegate.updateNodeHeartbeat(java.lang.String nodeId,
long heartbeat,
java.lang.String leaderNodeId) |
int |
JdbcDelegate.updateReassign(java.lang.String oldnode,
java.lang.String newnode) |
int |
DatabaseDelegate.updateReassign(java.lang.String oldnode,
java.lang.String newnode)
Reassign jobs from one node to another.
|
Copyright © 2021 WSO2. All Rights Reserved.