Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.actian.dataflow.cal.yarn.shared |
Constructor and 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) |
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) |
Modifier and Type | Method and Description |
---|---|
Map<String,ApplicationResource> |
YarnAppMasterArgs.getAppResources() |
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) |
Copyright © 2016 Actian Corporation. All rights reserved.