public interface DBConnector
Modifier and Type | Method and Description |
---|---|
void |
close() |
List<Jobs.JobDBEntry> |
fetchJobDetails(long minFinishTime,
long maxStartTime) |
List<Jobs.JobDBEntry> |
fetchJobDetails(String workflowID) |
long[] |
fetchJobStartStopTimes(String jobID) |
List<TaskAttempt> |
fetchJobTaskAttempts(String jobID) |
List<TaskAttempt> |
fetchTaskAttempts(long minFinishTime,
long maxStartTime) |
Workflows |
fetchWorkflows() |
DataTable |
fetchWorkflows(int offset,
int limit,
String searchTerm,
int echo,
Workflows.WorkflowDBEntry.WorkflowFields field,
boolean sortAscending,
String searchWorkflowId,
String searchWorkflowName,
String searchWorkflowType,
String searchUserName,
int minJobs,
int maxJobs,
long minInputBytes,
long maxInputBytes,
long minOutputBytes,
long maxOutputBytes,
long minDuration,
long maxDuration,
long minStartTime,
long maxStartTime,
long minFinishTime,
long maxFinishTime) |
Workflows |
fetchWorkflows(Workflows.WorkflowDBEntry.WorkflowFields field,
boolean sortAscending,
int offset,
int limit) |
List<TaskAttempt> |
fetchWorkflowTaskAttempts(String workflowID) |
void |
submitJob(Jobs.JobDBEntry j,
WorkflowContext context) |
void |
updateJob(Jobs.JobDBEntry j) |
void submitJob(Jobs.JobDBEntry j, WorkflowContext context) throws IOException
IOException
void updateJob(Jobs.JobDBEntry j) throws IOException
IOException
Workflows fetchWorkflows() throws IOException
IOException
Workflows fetchWorkflows(Workflows.WorkflowDBEntry.WorkflowFields field, boolean sortAscending, int offset, int limit) throws IOException
IOException
DataTable fetchWorkflows(int offset, int limit, String searchTerm, int echo, Workflows.WorkflowDBEntry.WorkflowFields field, boolean sortAscending, String searchWorkflowId, String searchWorkflowName, String searchWorkflowType, String searchUserName, int minJobs, int maxJobs, long minInputBytes, long maxInputBytes, long minOutputBytes, long maxOutputBytes, long minDuration, long maxDuration, long minStartTime, long maxStartTime, long minFinishTime, long maxFinishTime) throws IOException
IOException
List<Jobs.JobDBEntry> fetchJobDetails(String workflowID) throws IOException
IOException
List<Jobs.JobDBEntry> fetchJobDetails(long minFinishTime, long maxStartTime) throws IOException
IOException
long[] fetchJobStartStopTimes(String jobID) throws IOException
IOException
List<TaskAttempt> fetchJobTaskAttempts(String jobID) throws IOException
IOException
List<TaskAttempt> fetchWorkflowTaskAttempts(String workflowID) throws IOException
IOException
List<TaskAttempt> fetchTaskAttempts(long minFinishTime, long maxStartTime) throws IOException
IOException
void close()
Copyright © 2016. All rights reserved.