Module datarush.commons
Package 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 Details

    • 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