Package | Description |
---|---|
com.actian.dataflow.cal.yarn.server | |
com.pervasive.datarush.cal |
Provides interfaces the define the "cluster abstraction layer".
|
com.pervasive.datarush.cal.monitoring |
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 |
---|---|
ResourceAllocation |
NodeStatisticsSnapshot.getAllocatedResources() |
ResourceAllocation |
NodeStatistics.getAllocatedResources() |
Copyright © 2016 Actian Corporation. All rights reserved.