Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.dr | |
com.pervasive.datarush.cal.monitoring | |
com.pervasive.datarush.cluster |
Provides classes and interfaces related to the management of
clustered dataflow engines.
|
Modifier and Type | Method and Description |
---|---|
protected ResourceAllocation |
YarnClusterExecutor.getMasterResources() |
Modifier and Type | Field and Description |
---|---|
static ResourceAllocation |
ResourceAllocation.MASTER_DEFAULT |
static ResourceAllocation |
ResourceAllocation.NONE |
static ResourceAllocation |
ResourceAllocation.PARTITION_DEFAULT |
Modifier and Type | Method and Description |
---|---|
ResourceAllocation |
ResourceAllocation.add(ResourceAllocation other) |
ResourceAllocation |
ResourceAllocation.forWorker(int partitions)
Computes the resource allotment for a worker process.
|
ResourceAllocation |
NodeAllocationPlan.getJobMasterResources()
Gets the allocated resources for the job master.
|
ResourceAllocation |
NodeAllocationState.getPerPartitionResources()
Gets the per-partition resource allocation.
|
ResourceAllocation |
NodeAllocationPlan.getPerPartitionResources()
Gets the allocated allocated resources for each partition.
|
ResourceAllocation |
JobServerInformation.getResources() |
ResourceAllocation |
ResourceSpecifier.masterResources() |
ResourceAllocation |
ResourceSpecifier.partitionResources() |
ResourceAllocation |
ResourceAllocation.subtract(ResourceAllocation usage) |
Modifier and Type | Method and Description |
---|---|
ResourceAllocation |
ResourceAllocation.add(ResourceAllocation other) |
String |
ResourceAllocation.asPortion(ResourceAllocation usage) |
double |
ResourceAllocation.calculateDominantUsage(ResourceAllocation usage)
Computes the dominant share of resources for the specified usage
relative to this allocation.
|
int |
ResourceAllocation.calculatePartitions(ResourceAllocation usage)
Computes the number of partitions of the specified usage within the
allocation.
|
boolean |
ResourceAllocation.contains(ResourceAllocation other) |
static NodeAllocationPlan |
NodeAllocationPlan.create(String jobMasterNodeId,
ResourceAllocation masterResources,
List<NodeAllocationPlan.AssignmentPlan> assignments,
ResourceAllocation partitionResources,
NodeInformationMapping nodeMapping)
Creates a new node allocation.
|
ResourceSpecifier |
ResourceSpecifier.masterResources(ResourceAllocation resources)
Returns a resource specifier applying the specified allocation for
job master resources
|
ResourceSpecifier |
ResourceSpecifier.partitionResources(ResourceAllocation resources)
Returns a resource specifier applying the specified allocation for
per-partition resources
|
ResourceAllocation |
ResourceAllocation.subtract(ResourceAllocation usage) |
Constructor and Description |
---|
JobServerInformation(JobInformation jobInfo,
WorkerRole role,
ResourceAllocation resources) |
Modifier and Type | Method and Description |
---|---|
protected ResourceAllocation |
DRClusterExecutor.getMasterResources() |
protected ResourceAllocation |
AbstractDRClusterExecutor.getMasterResources() |
Constructor and Description |
---|
DRClusterExecutor(FileClient fileClient,
JobSpecifier jobSpec,
ExecutorOptions execOptions,
NodeAllocationProvider allocationProvider,
ResourceAllocation masterResources) |
Modifier and Type | Method and Description |
---|---|
ResourceAllocation |
NodeStatisticsSnapshot.getAllocatedResources() |
ResourceAllocation |
NodeStatistics.getAllocatedResources() |
Modifier and Type | Method and Description |
---|---|
ResourceAllocation |
NodeResourceState.getAvailableCapacity() |
ResourceAllocation |
NodeMapping.Entry.getResourceCapacity() |
ResourceAllocation |
NodeResourceState.getTotalCapacity() |
Modifier and Type | Method and Description |
---|---|
abstract NodePartitionPlan |
NodeAllocationStrategy.allocate(List<NodeResourceState> ordered,
int numPipelines,
ResourceAllocation partitionUsage) |
static DataRushCluster |
DataRushCluster.embedded(File workingDir,
int nodeCount,
int availableProcessorsPerNode,
ResourceAllocation nodeCapacity) |
static DataRushCluster |
DataRushCluster.embedded(File workingDir,
int nodeCount,
int availableProcessorsPerNode,
ResourceAllocation nodeCapacity,
Map<String,String> otherSettings) |
boolean |
NodeResourceState.hasAvailable(ResourceAllocation requested) |
void |
NodeResourceState.increment(ResourceAllocation inUse) |
static JvmOptions |
JvmOptions.options(ResourceAllocation resources) |
Constructor and Description |
---|
EmbeddedPreferencesProvider(File workingDir,
int availableProcessors,
ResourceAllocation capacity,
Map<String,String> otherSettings) |
NodeResourceState(String node,
ResourceAllocation capacity) |
Copyright © 2016 Actian Corporation. All Rights Reserved.