protected class WorkflowResourceProvider.PostgresWorkflowFetcher extends Object implements WorkflowResourceProvider.WorkflowFetcher
Constructor and Description |
---|
WorkflowResourceProvider.PostgresWorkflowFetcher(ConnectionFactory connectionFactory)
Create a postgres workflow fetcher that uses a given connection factory.
|
public WorkflowResourceProvider.PostgresWorkflowFetcher(ConnectionFactory connectionFactory)
connectionFactory
- a connection factoryprotected ResultSet getResultSet(Set<String> requestedIds, String workflowId) throws SQLException
SQLException
protected void close()
public Set<Resource> fetchWorkflows(Set<String> requestedIds, String clusterName, String workflowId)
WorkflowResourceProvider.WorkflowFetcher
fetchWorkflows
in interface WorkflowResourceProvider.WorkflowFetcher
requestedIds
- fields to pull from dbclusterName
- the cluster nameworkflowId
- the workflow idCopyright © 2014. All rights reserved.