Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.actian.dataflow.cal.yarn.shared | |
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
com.pervasive.datarush.cluster.preferences |
Constructor and Description |
---|
MasterServer(com.pervasive.datarush.hadoop.shims.yarn.AMRMClient amClient,
FileClient client,
Path drfsBaseDir,
JobServerInformation jobWorkerInfo,
JobSpecifier jobSpecifier,
ExecutorOptions execOptions,
List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors,
Path cacheLocation,
Path libArchiveLocation,
String applicationID,
int jobPriority,
ClusterPreferences clusterPreferences,
Map<String,ApplicationResource> appResources) |
YarnClusterExecutor(FileClient fileClient,
JobSpecifier jobSpec,
com.pervasive.datarush.hadoop.shims.yarn.ContainerManager containerMgr,
ExecutorOptions execOptions,
Path cacheLocation,
Path libArchiveLocation,
ClusterPreferences clusterPrefs,
Map<String,ApplicationResource> appResources) |
Modifier and Type | Method and Description |
---|---|
ClusterPreferences |
YarnAppMasterArgs.getClusterPreferences() |
Modifier and Type | Method and Description |
---|---|
static com.pervasive.datarush.hadoop.shims.yarn.ContainerContext |
ContainerContextBuilder.createContext(Platform targetPlatform,
ClasspathSpecifier classpathSpec,
String jobName,
Class<?> mainClass,
Path archivePath,
ClusterPreferences clusterPreferences)
Create a container context.
|
Constructor and Description |
---|
YarnAppMasterArgs(JobSpecifier jobSpec,
ModuleConfiguration moduleCfg,
FileMetaConfiguration fileCfg,
ClasspathSpecifier classpathSpec,
ExecutorOptions options,
List<com.pervasive.datarush.hadoop.shims.yarn.YarnNodeDescriptor> nodeDescriptors,
Path cacheLocation,
Path libArchiveLocation,
int jobPriority,
ClusterPreferences clusterPreferences,
Map<String,ApplicationResource> appResources) |
Modifier and Type | Method and Description |
---|---|
ClusterPreferences |
ClusterManagerImpl.getConfiguration() |
ClusterPreferences |
ClusterManager.getConfiguration()
Get the global cluster configuration (not for a specific node).
|
ClusterPreferences |
ClusterManagerImpl.getConfiguration(String node) |
ClusterPreferences |
ClusterManager.getConfiguration(String node)
Requests the configuration for the given node.
|
ClusterPreferences |
EmbeddedPreferencesProvider.getGlobalPreferences() |
ClusterPreferences |
DataRushCluster.getNodeConfiguration(String nodeID) |
ClusterPreferences |
EmbeddedPreferencesProvider.getNodeScopedPreferences(String nodeID) |
Modifier and Type | Method and Description |
---|---|
ExecutorOptions |
ExecutorOptions.applyClusterProperties(ClusterPreferences properties)
Creates a settings collection from a properties set.
|
void |
NodeManagerImpl.notifyNodePreferencesChanged(ClusterPreferences nodeScopedPreferences) |
void |
NodeManager.notifyNodePreferencesChanged(ClusterPreferences nodeScopedPreferences)
Notifies the node manager that their preferences (may) have changed
|
Constructor and Description |
---|
NodeMapping.Entry(NodeDescriptor descriptor,
ClusterPreferences preferences) |
Modifier and Type | Class and Description |
---|---|
class |
ClusterPreferencesImpl |
Modifier and Type | Field and Description |
---|---|
static ClusterPreferences |
ClusterPreferencesImpl.EMPTY |
Modifier and Type | Method and Description |
---|---|
ClusterPreferences |
EmptyPreferencesProvider.getGlobalPreferences() |
ClusterPreferences |
CompositePreferencesProvider.getGlobalPreferences() |
ClusterPreferences |
ClusterPreferencesProvider.getGlobalPreferences()
Returns the global preferences to be used when not in the context of a
specific node
|
ClusterPreferences |
EmptyPreferencesProvider.getNodeScopedPreferences(String nodeID) |
ClusterPreferences |
CompositePreferencesProvider.getNodeScopedPreferences(String nodeID) |
ClusterPreferences |
ClusterPreferencesProvider.getNodeScopedPreferences(String nodeID)
Returns the preferences to be used when in the context of a given node.
|
Copyright © 2015 Actian Corporation. All Rights Reserved.