Uses of Class
com.pervasive.datarush.cal.JobSpecifier

Packages that use JobSpecifier

Package	Description
com.actian.dataflow.cal.yarn.client
com.actian.dataflow.cal.yarn.server
com.actian.dataflow.cal.yarn.shared
com.pervasive.datarush.cal	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 JobSpecifier

Modifier and Type	Method	Description
JobExecutorService	YarnClusterProvider.createExecutor(FileClient fileClient, JobSpecifier spec)
protected com.pervasive.datarush.cal.dr.AbstractDRJobExecutor.JobMasterHelper	YarnClusterJobExecutor.start(FileClient fileClient, JobSpecifier jobSpec)

Constructors in com.actian.dataflow.cal.yarn.client with parameters of type JobSpecifier

Constructor	Description
YarnClusterJobExecutor(FileClient fileClient, JobSpecifier jobSpec)

Uses of JobSpecifier in com.actian.dataflow.cal.yarn.server

Methods in com.actian.dataflow.cal.yarn.server that return JobSpecifier

Modifier and Type	Method	Description
JobSpecifier	YarnWorkerArgs.getJobSpecifier()

Constructors in com.actian.dataflow.cal.yarn.server with parameters of type JobSpecifier

Constructor	Description
MasterServer(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.actian.dataflow.cal.yarn.shared

Methods in com.actian.dataflow.cal.yarn.shared that return JobSpecifier

Modifier and Type	Method	Description
JobSpecifier	YarnAppMasterArgs.getJobSpecifier()

Constructors in com.actian.dataflow.cal.yarn.shared with parameters of type JobSpecifier

Constructor

Description

YarnAppMasterArgs(JobSpecifier jobSpec, ModuleConfiguration moduleCfg, FileMetaConfiguration fileCfg, ClasspathSpecifier classpathSpec, com.pervasive.datarush.cluster.ExecutorOptions options, List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors, Path cacheLocation, Path libArchiveLocation, int jobPriority, com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences, Map<String,ApplicationResource> appResources)

Uses of JobSpecifier in com.pervasive.datarush.cal

Methods in com.pervasive.datarush.cal that return JobSpecifier

Modifier and Type	Method	Description
JobSpecifier	JobSpecifier.classpath(ClasspathSpecifier classpath)	Overrides the classpath
JobSpecifier	JobSpecifier.cluster(ClusterSpecifier cluster)	Overrides the cluster
JobSpecifier	JobSpecifier.extensionPaths(List<String> extensionPaths)	Overrides the extension paths
JobSpecifier	JobSpecifier.jobInformation(JobInformation jobInformation)	Overrides the jobInformation
JobSpecifier	JobSpecifier.schedulerQueue(String schedulerQueue)	Overrides the scheduler queue
JobSpecifier	JobSpecifier.storageManagementPath(Path storageManagementPath)	Overrides the storageManagementPath

Methods in com.pervasive.datarush.cal with parameters of type JobSpecifier

Modifier and Type	Method	Description
JobExecutorService	ClusterProvider.createExecutor(FileClient fileClient, JobSpecifier spec)	Create a new job executor service.
JobExecutorService	ClusterProviderManager.createExecutor(FileClient fileClient, JobSpecifier spec)	Create a new job executor service.
static JobExecutorService	JobExecutorServiceFactory.newJobExecutor(FileClient fileClient, JobSpecifier jobSpec)	Creates a new executor

Constructors in com.pervasive.datarush.cal with parameters of type JobSpecifier

Constructor	Description
StorageManagerSpecifier(JobSpecifier jobSpec, DistributedExecutorService service)	Create a jobInfo