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 © 2016 Actian Corporation. All rights reserved.