com.pervasive.datarush.cal

Class ClusterProviderManager

java.lang.Object

com.pervasive.datarush.cal.ClusterProviderManager

public final class ClusterProviderManager
extends Object

Facade to lookup providers from META-INF/services.

Method Summary

Modifier and Type	Method and Description
JobExecutorService	createExecutor(FileClient fileClient, JobSpecifier spec) Create a new job executor service.
String	getDefaultStorageManagementPath(ClusterSpecifier spec) Returns the default root path for this cluster provider.
static ClusterProviderManager	getInstance() Returns the single instance of this class
JobHistoryService	getJobHistoryService(FileClient client, ClusterSpecifier spec)
ClusterProvider	getProvider(ClusterSpecifier spec) Returns a provider that matches the given spec
void	validateConnection(FileClient client, ClusterSpecifier spec) Performs validation of the specifier

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static ClusterProviderManager getInstance()

Returns the single instance of this class

Returns:

the instance

getProvider

public ClusterProvider getProvider(ClusterSpecifier spec)

Returns a provider that matches the given spec

Parameters:

spec - the cluster specifier

Returns:

a matching cluster provider

validateConnection

public void validateConnection(FileClient client,
                               ClusterSpecifier spec)

Performs validation of the specifier

Parameters:

specifier -

getDefaultStorageManagementPath

public String getDefaultStorageManagementPath(ClusterSpecifier spec)

Returns the default root path for this cluster provider. For example, within the DR cluster, the default path is drfs://clustermanager:port.

Parameters:

spec - the cluster specifier

Returns:

the default root path

getJobHistoryService

public JobHistoryService getJobHistoryService(FileClient client,
                                              ClusterSpecifier spec)

createExecutor

public JobExecutorService createExecutor(FileClient fileClient,
                                         JobSpecifier spec)

Create a new job executor service.

Parameters:

fileClient - the file client to use

spec - the job specifier

Returns:

a new job executor service