org.apache.ambari.server.controller.internal

Class WorkflowResourceProvider.PostgresWorkflowFetcher

java.lang.Object

org.apache.ambari.server.controller.internal.WorkflowResourceProvider.PostgresWorkflowFetcher

All Implemented Interfaces:

WorkflowResourceProvider.WorkflowFetcher

Enclosing class:

WorkflowResourceProvider

protected class WorkflowResourceProvider.PostgresWorkflowFetcher
extends Object
implements WorkflowResourceProvider.WorkflowFetcher

A workflow fetcher that queries a postgres workflow table.

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresWorkflowFetcher

public PostgresWorkflowFetcher(ConnectionFactory connectionFactory)

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

Parameters:

connectionFactory - a connection factory

Method Detail

getResultSet

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

Throws:

SQLException

close

protected void close()

fetchWorkflows

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

Description copied from interface: WorkflowResourceProvider.WorkflowFetcher

Fetch workflow resources.

Specified by:

fetchWorkflows in interface WorkflowResourceProvider.WorkflowFetcher

Parameters:

requestedIds - fields to pull from db

clusterName - the cluster name

workflowId - the workflow id

Returns:

a set of workflow resources