org.apache.ambari.server.controller.internal

Class TaskAttemptResourceProvider.PostgresTaskAttemptFetcher

java.lang.Object

org.apache.ambari.server.controller.internal.TaskAttemptResourceProvider.PostgresTaskAttemptFetcher

All Implemented Interfaces:

TaskAttemptResourceProvider.TaskAttemptFetcher

Enclosing class:

TaskAttemptResourceProvider

protected class TaskAttemptResourceProvider.PostgresTaskAttemptFetcher
extends Object
implements TaskAttemptResourceProvider.TaskAttemptFetcher

A task attempt fetcher that queries a postgres task attempt table.

Constructor Summary

Constructors

Constructor and Description
PostgresTaskAttemptFetcher(ConnectionFactory connectionFactory) Create a postgres task attempt fetcher that uses a given connection factory.

Method Summary

Modifier and Type	Method and Description
protected void	close()
Set<Resource>	fetchTaskAttemptDetails(Set<String> requestedIds, String clusterName, String workflowId, String jobId, String taskAttemptId) Fetch task attempt resources
protected ResultSet	getResultSet(Set<String> requestedIds, String workflowId, String jobId, String taskAttemptId)

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresTaskAttemptFetcher

public PostgresTaskAttemptFetcher(ConnectionFactory connectionFactory)

Create a postgres task attempt 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,
                                 String taskAttemptId)
                          throws SQLException

Throws:

SQLException

close

protected void close()

fetchTaskAttemptDetails

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

Description copied from interface: TaskAttemptResourceProvider.TaskAttemptFetcher

Fetch task attempt resources

Specified by:

fetchTaskAttemptDetails in interface TaskAttemptResourceProvider.TaskAttemptFetcher

Parameters:

requestedIds - fields to pull from db

clusterName - the cluster name

workflowId - the workflow id

jobId - the job id

taskAttemptId - the task attempt id

Returns:

a set of task attempt resources