Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.actian.dataflow.cal.yarn.shared | |
com.pervasive.datarush.cal.dr | |
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
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 |
---|---|
ExecutorOptions |
YarnAppMasterArgs.getOptions() |
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) |
Constructor and Description |
---|
DRClusterExecutor(FileClient fileClient,
JobSpecifier jobSpec,
ExecutorOptions execOptions,
NodeAllocationProvider allocationProvider,
ResourceAllocation masterResources) |
Modifier and Type | Method and Description |
---|---|
ExecutorOptions |
ExecutorOptions.allocationStrategy(NodeAllocationStrategy allocationStrategy) |
ExecutorOptions |
ExecutorOptions.applyClusterProperties(ClusterPreferences properties)
Creates a settings collection from a properties set.
|
ExecutorOptions |
DataRushCluster.getDefaultFragmentOptions()
Gets the global default settings for graph fragment execution.
|
ExecutorOptions |
ClusterManagerImpl.getDefaultOptions() |
ExecutorOptions |
ClusterManager.getDefaultOptions()
Gets the default options configured for remote fragment
execution.
|
ExecutorOptions |
WorkerServerArguments.getOptions() |
ExecutorOptions |
ClientWorkerServerArguments.getOptions() |
ExecutorOptions |
ExecutorOptions.loggingLevels(Map<String,String> loggingLevels) |
ExecutorOptions |
ExecutorOptions.masterOptions(JvmOptions masterOptions) |
ExecutorOptions |
ExecutorOptions.maximumParallelism(int parallelism) |
ExecutorOptions |
ExecutorOptions.minimumParallelism(int parallelism) |
static ExecutorOptions |
ExecutorOptions.options() |
ExecutorOptions |
ExecutorOptions.workerOptions(JvmOptions workerOptions) |
Modifier and Type | Method and Description |
---|---|
void |
WorkerServerArguments.setOptions(ExecutorOptions options) |
Constructor and Description |
---|
ClientWorkerServerArguments(JobServerInformation jobServerInfo,
JobClasspathConfig classpath,
ExecutorOptions options,
PassThru<ClientPassThru> clientPassThru) |
WorkerServer(FileClient client,
Path drfsBaseDir,
String nodeID,
JobServerInformation jobWorkerInfo,
JobSpecifier jobSpecifier,
ExecutorOptions execOptions,
NodeAllocationProvider allocationProvider,
String host) |
Copyright © 2016 Actian Corporation. All Rights Reserved.