org.apache.ambari.eventdb.db

Interface DBConnector

All Known Implementing Classes:

MySQLConnector, OracleConnector, PostgresConnector

public interface DBConnector

Method Summary

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)

Method Detail

submitJob

void submitJob(Jobs.JobDBEntry j,
               WorkflowContext context)
        throws IOException

Throws:

IOException

updateJob

void updateJob(Jobs.JobDBEntry j)
        throws IOException

Throws:

IOException

fetchWorkflows

Workflows fetchWorkflows()
                  throws IOException

Throws:

IOException

fetchWorkflows

Workflows fetchWorkflows(Workflows.WorkflowDBEntry.WorkflowFields field,
                         boolean sortAscending,
                         int offset,
                         int limit)
                  throws IOException

Throws:

IOException

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)
                  throws IOException

Throws:

IOException

fetchJobDetails

List<Jobs.JobDBEntry> fetchJobDetails(String workflowID)
                               throws IOException

Throws:

IOException

fetchJobDetails

List<Jobs.JobDBEntry> fetchJobDetails(long minFinishTime,
                                      long maxStartTime)
                               throws IOException

Throws:

IOException

fetchJobStartStopTimes

long[] fetchJobStartStopTimes(String jobID)
                       throws IOException

Throws:

IOException

fetchJobTaskAttempts

List<TaskAttempt> fetchJobTaskAttempts(String jobID)
                                throws IOException

Throws:

IOException

fetchWorkflowTaskAttempts

List<TaskAttempt> fetchWorkflowTaskAttempts(String workflowID)
                                     throws IOException

Throws:

IOException

fetchTaskAttempts

List<TaskAttempt> fetchTaskAttempts(long minFinishTime,
                                    long maxStartTime)
                             throws IOException

Throws:

IOException

close

void close()