org.apache.ambari.server.controller.internal

Class JobResourceProvider.PostgresJobFetcher

java.lang.Object

org.apache.ambari.server.controller.internal.JobResourceProvider.PostgresJobFetcher

All Implemented Interfaces:

JobResourceProvider.JobFetcher

Enclosing class:

JobResourceProvider

protected class JobResourceProvider.PostgresJobFetcher
extends Object
implements JobResourceProvider.JobFetcher

A job fetcher that queries a postgres job table.

Constructor Summary

Constructors

Constructor and Description
PostgresJobFetcher(ConnectionFactory connectionFactory) Create a postgres job fetcher that uses a given connection factory.

Method Summary

Modifier and Type	Method and Description
protected void	close()
Set<Resource>	fetchJobDetails(Set<String> requestedIds, String clusterName, String workflowId, String jobId) Fetch job resources.
protected ResultSet	getResultSet(Set<String> requestedIds, String workflowId, String jobId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PostgresJobFetcher

public PostgresJobFetcher(ConnectionFactory connectionFactory)

Create a postgres job fetcher that uses a given connection factory.

Parameters:

connectionFactory - a connection factory

Method Detail

getResultSet

protected ResultSet getResultSet(Set<String> requestedIds,
                                 String workflowId,
                                 String jobId)
                          throws SQLException

Throws:

SQLException

close

protected void close()

fetchJobDetails

public Set<Resource> fetchJobDetails(Set<String> requestedIds,
                                     String clusterName,
                                     String workflowId,
                                     String jobId)

Description copied from interface: JobResourceProvider.JobFetcher

Fetch job resources.

Specified by:

fetchJobDetails in interface JobResourceProvider.JobFetcher

Parameters:

requestedIds - fields to pull from db

clusterName - the cluster name

workflowId - the workflow id

jobId - the job id

Returns:

a set of job resources