Module datarush.commons
Package com.pervasive.datarush.cal

Class ClusterProviderManager

  • public final class ClusterProviderManager
extends Object
    Facade to lookup providers from META-INF/services.

    • 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

      • 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