org.apache.ambari.server.controller.internal

Class ClusterControllerImpl

java.lang.Object

org.apache.ambari.server.controller.internal.ClusterControllerImpl

All Implemented Interfaces:

ClusterController, SchemaFactory

public class ClusterControllerImpl
extends Object
implements ClusterController

Default cluster controller implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ClusterControllerImpl.ResourceComparator

Constructor Summary

Constructors

Constructor and Description
ClusterControllerImpl(ProviderModule providerModule)

Method Summary

Modifier and Type	Method and Description
RequestStatus	createResources(Resource.Type type, Request request) Create the resources defined by the properties in the given request object.
RequestStatus	deleteResources(Resource.Type type, Request request, Predicate predicate) Delete the resources selected by the given predicate.
ResourceProvider	ensureResourceProvider(Resource.Type type) Provides a non-wrapped resource provider..
Predicate	getAmendedPredicate(Resource.Type type, Predicate predicate) Gets the amended predicate for a resource.
protected Comparator<Resource>	getComparator() Get the associated resource comparator.
Iterable<Resource>	getIterable(Resource.Type type, QueryResponse queryResponse, Request request, Predicate predicate, PageRequest pageRequest, SortRequest sortRequest) Get an iterable set of resources from the given set of resources filtered by the given request and predicate objects.
PageResponse	getPage(Resource.Type type, QueryResponse queryResponse, Request request, Predicate predicate, PageRequest pageRequest, SortRequest sortRequest) Get a page of resources from the given set filtered by the given request, predicate objects and page request.
protected Iterable<Resource>	getResourceIterable(Resource.Type type, Request request, Predicate predicate) Get an iterable set of resources filtered by the given request and predicate objects.
QueryResponse	getResources(Resource.Type type, Request request, Predicate predicate) Get the resources of the given type filtered by the given request and predicate objects.
protected PageResponse	getResources(Resource.Type type, Request request, Predicate predicate, PageRequest pageRequest, SortRequest sortRequest) Get a page of resources filtered by the given request, predicate objects and page request.
Schema	getSchema(Resource.Type type) Get the schema for the given resource type.
Set<Resource>	populateResources(Resource.Type type, Set<Resource> resources, Request request, Predicate predicate) Populate the given resources from the associated property providers.
RequestStatus	updateResources(Resource.Type type, Request request, Predicate predicate) Update the resources selected by the given predicate with the properties from the given request object.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterControllerImpl

public ClusterControllerImpl(ProviderModule providerModule)

Method Detail

getAmendedPredicate

public Predicate getAmendedPredicate(Resource.Type type,
                                     Predicate predicate)

Description copied from interface: ClusterController

Gets the amended predicate for a resource.

Specified by:

getAmendedPredicate in interface ClusterController

Parameters:

type - the type of the resource

predicate - the predicate object to use for filtering

Returns:

the new predicate used for filtering

getResources

public QueryResponse getResources(Resource.Type type,
                                  Request request,
                                  Predicate predicate)
                           throws UnsupportedPropertyException,
                                  NoSuchResourceException,
                                  NoSuchParentResourceException,
                                  SystemException

Description copied from interface: ClusterController

Get the resources of the given type filtered by the given request and predicate objects.

Specified by:

getResources in interface ClusterController

Parameters:

type - the type of the requested resources

request - the request object which defines the desired set of properties

predicate - the predicate object which filters which resources are returned

Returns:

the query response

Throws:

UnsupportedPropertyException - thrown if the request or predicate contain unsupported property ids

NoSuchResourceException - no matching resource(s) found

NoSuchParentResourceException - a specified parent resource doesn't exist

SystemException - an internal exception occurred

populateResources

public Set<Resource> populateResources(Resource.Type type,
                                       Set<Resource> resources,
                                       Request request,
                                       Predicate predicate)
                                throws SystemException

Description copied from interface: ClusterController

Populate the given resources from the associated property providers. This method may filter the resources based on the predicate and return a subset of the given resources.

Specified by:

populateResources in interface ClusterController

Parameters:

type - the resource type

resources - the resources to be populated

request - the request

predicate - the predicate

Returns:

the set of resources that were successfully populated

Throws:

SystemException - if unable to populate the resources

getIterable

public Iterable<Resource> getIterable(Resource.Type type,
                                      QueryResponse queryResponse,
                                      Request request,
                                      Predicate predicate,
                                      PageRequest pageRequest,
                                      SortRequest sortRequest)
                               throws NoSuchParentResourceException,
                                      UnsupportedPropertyException,
                                      NoSuchResourceException,
                                      SystemException

Description copied from interface: ClusterController

Get an iterable set of resources from the given set of resources filtered by the given request and predicate objects.

Specified by:

getIterable in interface ClusterController

Parameters:

type - type of resources

queryResponse - the response from the resource query

request - the request

predicate - the predicate object which filters which resources are returned

pageRequest - the page request for a paginated response

sortRequest - the sortRequest object which defines if the resources need to be sorted

Returns:

a page response representing the requested page of resources

Throws:

NoSuchParentResourceException - a specified parent resource doesn't exist

UnsupportedPropertyException - thrown if the request or predicate contain unsupported property ids

NoSuchResourceException - no matching resource(s) found

SystemException - an internal exception occurred

getPage

public PageResponse getPage(Resource.Type type,
                            QueryResponse queryResponse,
                            Request request,
                            Predicate predicate,
                            PageRequest pageRequest,
                            SortRequest sortRequest)
                     throws UnsupportedPropertyException,
                            SystemException,
                            NoSuchResourceException,
                            NoSuchParentResourceException

Description copied from interface: ClusterController

Get a page of resources from the given set filtered by the given request, predicate objects and page request.

Specified by:

getPage in interface ClusterController

Parameters:

type - type of resources

queryResponse - the response from the resource query

request - the request

predicate - the predicate object which filters which resources are returned

pageRequest - the page request for a paginated response

Returns:

a page response representing the requested page of resources

Throws:

UnsupportedPropertyException - thrown if the request or predicate contain unsupported property ids

SystemException - an internal exception occurred

NoSuchResourceException - no matching resource(s) found

NoSuchParentResourceException - a specified parent resource doesn't exist

getSchema

public Schema getSchema(Resource.Type type)

Description copied from interface: ClusterController

Get the schema for the given resource type. The schema for a given resource type describes the properties and categories provided by that type of resource.

Specified by:

getSchema in interface ClusterController

Specified by:

getSchema in interface SchemaFactory

Parameters:

type - the resource type

Returns:

the schema object for the given resource

createResources

public RequestStatus createResources(Resource.Type type,
                                     Request request)
                              throws UnsupportedPropertyException,
                                     SystemException,
                                     ResourceAlreadyExistsException,
                                     NoSuchParentResourceException

Description copied from interface: ClusterController

Create the resources defined by the properties in the given request object.

Specified by:

createResources in interface ClusterController

Parameters:

type - the type of the resources

request - the request object which defines the set of properties for the resources to be created

Throws:

UnsupportedPropertyException - thrown if the request contains unsupported property ids

SystemException - an internal exception occurred

ResourceAlreadyExistsException - attempted to create a resource that already exists

NoSuchParentResourceException - a specified parent resource doesn't exist

updateResources

public RequestStatus updateResources(Resource.Type type,
                                     Request request,
                                     Predicate predicate)
                              throws UnsupportedPropertyException,
                                     SystemException,
                                     NoSuchResourceException,
                                     NoSuchParentResourceException

Description copied from interface: ClusterController

Update the resources selected by the given predicate with the properties from the given request object.

Specified by:

updateResources in interface ClusterController

Parameters:

type - the type of the resources

request - the request object which defines the set of properties for the resources to be updated

predicate - the predicate object which can be used to filter which resources are updated

Throws:

UnsupportedPropertyException - thrown if the request or predicate contain unsupported property ids

SystemException - an internal exception occurred

NoSuchResourceException - no matching resource(s) found

NoSuchParentResourceException - a specified parent resource doesn't exist

deleteResources

public RequestStatus deleteResources(Resource.Type type,
                                     Request request,
                                     Predicate predicate)
                              throws UnsupportedPropertyException,
                                     SystemException,
                                     NoSuchResourceException,
                                     NoSuchParentResourceException

Description copied from interface: ClusterController

Delete the resources selected by the given predicate.

Specified by:

deleteResources in interface ClusterController

Parameters:

type - the type of the resources

request - the request object which defines the set of properties for the resources to be deleted

predicate - the predicate object which can be used to filter which resources are deleted

Throws:

UnsupportedPropertyException - thrown if the predicate contains unsupported property ids

SystemException - an internal exception occurred

NoSuchResourceException - no matching resource(s) found

NoSuchParentResourceException - a specified parent resource doesn't exist

ensureResourceProvider

public ResourceProvider ensureResourceProvider(Resource.Type type)

Provides a non-wrapped resource provider..

Specified by:

ensureResourceProvider in interface ClusterController

Parameters:

type - type of resource provider to obtain

Returns:

a non-wrapped resource provider

getResourceIterable

protected Iterable<Resource> getResourceIterable(Resource.Type type,
                                                 Request request,
                                                 Predicate predicate)
                                          throws UnsupportedPropertyException,
                                                 SystemException,
                                                 NoSuchParentResourceException,
                                                 NoSuchResourceException

Get an iterable set of resources filtered by the given request and predicate objects.

Parameters:

type - type of resources

request - the request

predicate - the predicate object which filters which resources are returned

Returns:

a page response representing the requested page of resources

Throws:

UnsupportedPropertyException - thrown if the request or predicate contain unsupported property ids

SystemException - an internal exception occurred

NoSuchResourceException - no matching resource(s) found

NoSuchParentResourceException - a specified parent resource doesn't exist

getResources

protected PageResponse getResources(Resource.Type type,
                                    Request request,
                                    Predicate predicate,
                                    PageRequest pageRequest,
                                    SortRequest sortRequest)
                             throws UnsupportedPropertyException,
                                    SystemException,
                                    NoSuchResourceException,
                                    NoSuchParentResourceException

Get a page of resources filtered by the given request, predicate objects and page request.

Parameters:

type - type of resources

request - the request

predicate - the predicate object which filters which resources are returned

pageRequest - the page request for a paginated response

Returns:

a page response representing the requested page of resources

Throws:

UnsupportedPropertyException - thrown if the request or predicate contain unsupported property ids

SystemException - an internal exception occurred

NoSuchResourceException - no matching resource(s) found

NoSuchParentResourceException - a specified parent resource doesn't exist

getComparator

protected Comparator<Resource> getComparator()

Get the associated resource comparator.

Returns:

the resource comparator