Uses of Class
com.pervasive.datarush.cal.ClusterSpecifier
Packages that use ClusterSpecifier
Package
Description
Provides interfaces the define the "cluster abstraction layer".
Provides classes and interfaces for the construction of executable
dataflow graphs.
-
Uses of ClusterSpecifier in com.actian.dataflow.cal.yarn.client
Methods in com.actian.dataflow.cal.yarn.client with parameters of type ClusterSpecifierModifier and TypeMethodDescriptionstatic com.pervasive.datarush.hadoop.shims.yarn.ResourceManagerClientYarnShimFactory.createClient(ClusterSpecifier clusterSpec, ModuleConfiguration moduleCfg) Get a client interface to the YARN Resource Manager.YarnClusterProvider.getDefaultStorageManagementPath(ClusterSpecifier spec) YarnClusterProvider.getJobHistoryService(FileClient fileClient, ClusterSpecifier spec) booleanYarnClusterProvider.isProviderFor(ClusterSpecifier spec) voidYarnClusterProvider.validateConnection(FileClient fileClient, ClusterSpecifier spec) -
Uses of ClusterSpecifier in com.pervasive.datarush.cal
Fields in com.pervasive.datarush.cal declared as ClusterSpecifierModifier and TypeFieldDescriptionstatic final ClusterSpecifierClusterSpecifier.PSEUDO_DISTRIBUTEDConstant for the pseudo-distributed clusterMethods in com.pervasive.datarush.cal that return ClusterSpecifierModifier and TypeMethodDescriptionJobSpecifier.cluster()Returns the cluster on which to run the jobstatic ClusterSpecifierClusterSpecifier.create()Returns a cluster specifier with default settings.Returns a new specifier with the host set to the specified valueReturns a new specifier with the given option set to the specified valueReturns a new specifier with the given option set to the specified valueReturns a new specifier with the options set to the specified valuestatic ClusterSpecifierParses the given cluster specifier string.ClusterSpecifier.port(int port) Returns a new specifier with the port set to the specified valueReturns a new specifier with the scheme set to the specified valueMethods in com.pervasive.datarush.cal with parameters of type ClusterSpecifierModifier and TypeMethodDescriptionJobSpecifier.cluster(ClusterSpecifier cluster) Overrides the clusterClusterProvider.getDefaultStorageManagementPath(ClusterSpecifier spec) Returns the default root path for this cluster provider.ClusterProviderManager.getDefaultStorageManagementPath(ClusterSpecifier spec) Returns the default root path for this cluster provider.ClusterProvider.getJobHistoryService(FileClient client, ClusterSpecifier spec) ClusterProviderManager.getJobHistoryService(FileClient client, ClusterSpecifier spec) ClusterProviderManager.getProvider(ClusterSpecifier spec) Returns a provider that matches the given specbooleanClusterProvider.isProviderFor(ClusterSpecifier spec) Returns whether this provider is the correct provider for the given specifier.voidClusterProvider.validateConnection(FileClient fileClient, ClusterSpecifier spec) Gives the provider an opportunity to validate the specifiervoidClusterProviderManager.validateConnection(FileClient client, ClusterSpecifier spec) Performs validation of the specifierConstructors in com.pervasive.datarush.cal with parameters of type ClusterSpecifierModifierConstructorDescriptionJobSpecifier(ResourceSpecifier requestedResources, ClusterSpecifier cluster, ClasspathSpecifier classpath, JobInformation jobInformation, Path storageManagementPath) Create a new job specifierJobSpecifier(ResourceSpecifier requestedResources, ClusterSpecifier cluster, ClasspathSpecifier classpath, JobInformation jobInformation, Path storageManagementPath, String schedulerQueue, List<String> extensionPaths) Create a new job specifier -
Uses of ClusterSpecifier in com.pervasive.datarush.graphs
Fields in com.pervasive.datarush.graphs with type parameters of type ClusterSpecifierModifier and TypeFieldDescriptionstatic final EngineProperty<ClusterSpecifier>EngineConfig.CLUSTERProperty controls which cluster to run onMethods in com.pervasive.datarush.graphs that return ClusterSpecifierMethods in com.pervasive.datarush.graphs with parameters of type ClusterSpecifierModifier and TypeMethodDescriptionEngineConfig.cluster(ClusterSpecifier spec) Specifies the cluster on which we are to run