com.pervasive.datarush.cal.dr

Class DRClusterProvider

java.lang.Object

com.pervasive.datarush.cal.dr.DRClusterProvider

All Implemented Interfaces:

ClusterProvider

public class DRClusterProvider
extends Object
implements ClusterProvider

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROTOCOL

Constructor Summary

Constructors

Constructor and Description
DRClusterProvider()

Method Summary

Methods

Modifier and Type	Method and Description
JobExecutorService	createExecutor(FileClient fileClient, JobSpecifier jobSpec) Create a new job executor service.
String	getDefaultStorageManagementPath(ClusterSpecifier spec) Returns the default root path for this cluster provider.
JobHistoryService	getJobHistoryService(FileClient client, ClusterSpecifier spec)
boolean	isProviderFor(ClusterSpecifier spec) Returns whether this provider is the correct provider for the given specifier.
void	validateConnection(FileClient client, ClusterSpecifier spec) Gives the provider an opportunity to validate the specifier

Methods inherited from class java.lang.Object

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

Field Detail

PROTOCOL

public static final String PROTOCOL

See Also:

Constant Field Values

Constructor Detail

DRClusterProvider

public DRClusterProvider()

Method Detail

isProviderFor

public boolean isProviderFor(ClusterSpecifier spec)

Description copied from interface: ClusterProvider

Returns whether this provider is the correct provider for the given specifier.

Specified by:

isProviderFor in interface ClusterProvider

Parameters:

spec - the specifier

Returns:

whether this provider knows how to handle the given specifier

createExecutor

public JobExecutorService createExecutor(FileClient fileClient,
                                JobSpecifier jobSpec)

Description copied from interface: ClusterProvider

Create a new job executor service.

Specified by:

createExecutor in interface ClusterProvider

Parameters:

fileClient - the file client to use

jobSpec - the job specifier

Returns:

a new job executor service

getDefaultStorageManagementPath

public String getDefaultStorageManagementPath(ClusterSpecifier spec)

Description copied from interface: ClusterProvider

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

Specified by:

getDefaultStorageManagementPath in interface ClusterProvider

Parameters:

spec - the cluster specifier

Returns:

the default root path

validateConnection

public void validateConnection(FileClient client,
                      ClusterSpecifier spec)

Description copied from interface: ClusterProvider

Gives the provider an opportunity to validate the specifier

Specified by:

validateConnection in interface ClusterProvider

spec - the specifier

getJobHistoryService

public JobHistoryService getJobHistoryService(FileClient client,
                                     ClusterSpecifier spec)

Specified by:

getJobHistoryService in interface ClusterProvider