Uses of Class
com.pervasive.datarush.cal.JobSpecifier
Packages that use JobSpecifier
Package
Description
Provides interfaces the define the "cluster abstraction layer".
-
Uses of JobSpecifier in com.actian.dataflow.cal.yarn.client
Methods in com.actian.dataflow.cal.yarn.client with parameters of type JobSpecifierModifier and TypeMethodDescriptionYarnClusterProvider.createExecutor(FileClient fileClient, JobSpecifier spec) protected com.pervasive.datarush.cal.dr.AbstractDRJobExecutor.JobMasterHelperYarnClusterJobExecutor.start(FileClient fileClient, JobSpecifier jobSpec) Constructors in com.actian.dataflow.cal.yarn.client with parameters of type JobSpecifierModifierConstructorDescriptionYarnClusterJobExecutor(FileClient fileClient, JobSpecifier jobSpec) -
Uses of JobSpecifier in com.actian.dataflow.cal.yarn.server
Methods in com.actian.dataflow.cal.yarn.server that return JobSpecifierConstructors in com.actian.dataflow.cal.yarn.server with parameters of type JobSpecifierModifierConstructorDescriptionMasterServer(com.pervasive.datarush.hadoop.shims.yarn.AMRMClient amClient, FileClient client, Path drfsBaseDir, JobServerInformation jobWorkerInfo, JobSpecifier jobSpecifier, com.pervasive.datarush.cluster.ExecutorOptions execOptions, List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors, Path cacheLocation, Path libArchiveLocation, String applicationID, int jobPriority, com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences, Map<String, ApplicationResource> appResources) PartitionServer(FileClient client, Path drfsBaseDir, String nodeID, JobServerInformation jobWorkerInfo, com.pervasive.datarush.cal.dr.NodeAllocationProvider allocationProvider, JobSpecifier jobSpecifier) YarnClusterExecutor(FileClient fileClient, JobSpecifier jobSpec, com.pervasive.datarush.hadoop.shims.yarn.ContainerManager containerMgr, com.pervasive.datarush.cluster.ExecutorOptions execOptions, Path cacheLocation, Path libArchiveLocation, com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPrefs, Map<String, ApplicationResource> appResources) YarnWorkerArgs(JobSpecifier jobSpec, ModuleConfiguration moduleConfiguration, FileMetaConfiguration configuration, com.pervasive.datarush.cal.dr.NodeAllocationProvider provider) -
Uses of JobSpecifier in com.pervasive.datarush.cal
Methods in com.pervasive.datarush.cal that return JobSpecifierModifier and TypeMethodDescriptionJobSpecifier.classpath(ClasspathSpecifier classpath) Overrides the classpathJobSpecifier.cluster(ClusterSpecifier cluster) Overrides the clusterJobSpecifier.extensionPaths(List<String> extensionPaths) Overrides the extension pathsJobSpecifier.jobInformation(JobInformation jobInformation) Overrides the jobInformationJobSpecifier.schedulerQueue(String schedulerQueue) Overrides the scheduler queueJobSpecifier.storageManagementPath(Path storageManagementPath) Overrides the storageManagementPathMethods in com.pervasive.datarush.cal with parameters of type JobSpecifierModifier and TypeMethodDescriptionClusterProvider.createExecutor(FileClient fileClient, JobSpecifier spec) Create a new job executor service.ClusterProviderManager.createExecutor(FileClient fileClient, JobSpecifier spec) Create a new job executor service.static JobExecutorServiceJobExecutorServiceFactory.newJobExecutor(FileClient fileClient, JobSpecifier jobSpec) Creates a new executorConstructors in com.pervasive.datarush.cal with parameters of type JobSpecifierModifierConstructorDescriptionStorageManagerSpecifier(JobSpecifier jobSpec, DistributedExecutorService service) Create a jobInfo