| Package | Description | 
|---|---|
| com.actian.dataflow.cal.yarn.shared | |
| com.pervasive.datarush.cal | 
 Provides interfaces the define the "cluster abstraction layer". 
 | 
| com.pervasive.datarush.graphs | 
 Provides classes and interfaces for the construction of executable
 dataflow graphs. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ClasspathSpecifier | 
YarnAppMasterArgs.getClasspathSpecifier()  | 
| Modifier and Type | Method and Description | 
|---|---|
static com.pervasive.datarush.hadoop.shims.yarn.ContainerContext | 
ContainerContextBuilder.createContext(com.pervasive.datarush.cluster.Platform targetPlatform,
             ClasspathSpecifier classpathSpec,
             String jobName,
             Class<?> mainClass,
             Path archivePath,
             com.pervasive.datarush.cluster.preferences.ClusterPreferences clusterPreferences)
Create a container context. 
 | 
| Constructor and 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)  | 
| Modifier and Type | Method and Description | 
|---|---|
ClasspathSpecifier | 
JobSpecifier.classpath()
Returns the classpath of the job 
 | 
static ClasspathSpecifier | 
ClasspathSpecifier.defaultSpecifier()
Returns the default classpath specifier based on the system property java.class.path. 
 | 
ClasspathSpecifier | 
ClasspathSpecifier.resolve()
If this is the default, this will force resolution of the default classpath. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
JobSpecifier | 
JobSpecifier.classpath(ClasspathSpecifier classpath)
Overrides the classpath 
 | 
| Constructor and Description | 
|---|
JobSpecifier(ResourceSpecifier requestedResources,
            ClusterSpecifier cluster,
            ClasspathSpecifier classpath,
            JobInformation jobInformation,
            Path storageManagementPath)
Create a new job specifier 
 | 
JobSpecifier(ResourceSpecifier requestedResources,
            ClusterSpecifier cluster,
            ClasspathSpecifier classpath,
            JobInformation jobInformation,
            Path storageManagementPath,
            String schedulerQueue,
            List<String> extensionPaths)
Create a new job specifier 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static EngineProperty<ClasspathSpecifier> | 
EngineConfig.CLASSPATH_SPECIFIER
Property controlling classpath that is used for launching remote jobs 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ClasspathSpecifier | 
EngineConfig.getClasspathSpecifier()
Returns the classpath to be used in the case of a remote job. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
EngineConfig | 
EngineConfig.classpathSpecifier(ClasspathSpecifier classpath)
Sets the classpath to be used in the case of a remote job. 
 | 
Copyright © 2024 Actian Corporation. All rights reserved.